●介绍
有时候执行一个任务需要很长时间,单线程下线程会处于阻塞状态。这个时候我们会考虑一种非阻塞的处理模式。非阻塞任务在任何编程语言里都必不可少,Java也不例外。多线程就是一个很好的解决办法。
但是多线程是异步处理,异步就意味着不知道处理结果,如果我们需要知道处理结果的时候应该怎么办呢? 笔者介绍下面两种方法
●Callback
回调一般是异步处理的一种技术。一个回调是被传递到并且执行完该方法。 这种方式只能异步回调,如果需要同步等待线程处理结果可以使用下面介绍的Futures
import java.util.Map;
public interface ICallback {
public void callback(Map<String, Object> params);
}
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class NettyTest {
static ExecutorService es = Executors.newFixedThreadPool(2);
public static void doStm(final ICallback callback) {
// 初始化一个线程
Thread t = new Thread() {
public void run() {
// 这里是业务逻辑处理
System.out.println("do sth...");
// 为了能看出效果 ,让当前线程阻塞5秒
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 处理完业务逻辑,
Map<String, Object> params = new HashMap<String, Object>();
params.put("a1", "这是我返回的参数字符串...");
callback.callback(params);
};
};
es.execute(t);
}
public static void main(String[] args) {
// 内部类 等价于 ICallback callbck = new ICallback的实现类();
// 新手如果对内部类的写法有疑惑可以查看一下编译后的class文件或许能明白
// 在编译的时候会把内部类编译成一个实现了ICallback的class
doStm(new ICallback() {
/**
* 现在这个方法是doStm结束后调用<br>
* 结束之后会主动把处理参数params传递过来
*/
@Override
public void callback(Map<String, Object> params) {
System.out.println("单个线程也已经处理完毕了,返回参数a1=" + params.get("a1"));
}
});
System.out.println("主线任务已经执行完了");
}
}
●Future
Futures是一个抽象的概念,它表示一个值,该值可能在某一点变得可用。一个Future要么获得
计算完的结果,要么获得计算失败后的异常。Java在java.util.concurrent包中附带了Future接口,它使用Executor异步执行。例
如下面的代码,每传递一个Runnable对象到ExecutorService.submit()方法就会得到一个回调的Future,你能使用它检测是否执行,这种方法可以是同步等待线处理结果
完成。
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class NettyTest {
public static void main(String[] args) {
//实现一个Callable接口
Callable<Netty> c = new Callable<NettyTest.Netty>() {
@Override
public Netty call() throws Exception {
//这里是你的业务逻辑处理
//让当前线程阻塞5秒看下效果
Thread.sleep(5000);
return new Netty("张三");
}
};
ExecutorService es = Executors.newFixedThreadPool(2);
//记得要用submit,执行Callable对象
Future<Netty> fn = es.submit(c);
//无限循环等待任务处理完毕 如果已经处理完毕 isDone返回true
while (!fn.isDone()) {
try {
//处理完毕后返回的结果
Netty nt = fn.get();
System.out.println(nt.name);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
static class Netty {
private Netty(String name) {
this.name = name;
}
private String name;
}
}
分享到:
相关推荐
这几天搞搞JNA,主要是组内...C++部分使用ACE实现了一个线程,线程中调用Java部分的回调函数。 C++使用vc8开发,代码跨平台,不过偷懒,没写makefile, 其中使用了ACE这个库。 Java部分,使用eclipse。jdk1.5版本。
Java回调函数,也称为Callback机制,是面向对象编程中一种重要的设计模式,它允许一个对象在其他对象执行特定操作后得到通知或者进行后续处理。在Java中,回调通常通过接口来实现,因为Java不支持函数指针。让我们...
3. **Callback机制**: 异步请求的核心是回调函数。开发者可以定义一个实现了`FutureCallback<HttpResponse>`接口的类,覆盖`completed()`, `failed()`, 和 `cancelled()` 方法来处理不同的响应状态。 4. **流式处理...
异步调用是一种非阻塞的调用方式,调用方在调用过程中,不直接等待返回结果,而是执行其他任务,结果返回形式通常为回调函数。SYNC调用是指调用方在调用过程中,持续等待返回结果。Java中将异步调用转换为同步调用有...
总之,Java回调是软件设计中一个强大的工具,尤其在处理异步操作和事件驱动编程时。通过实践这个demo,你将能够更好地掌握这一关键概念,并将其应用到自己的项目中。记得不断地练习和探索,理论结合实践,你的Java...
为了解决这个问题,Java社区发展出了诸如RxJava这样的库,它们提供了一种更优雅的方式来处理回调和异步编程,通过链式调用和操作符重载来组合异步操作。 总的来说,回调是Java中实现异步处理和事件响应的一种常见...
异步回调模型下的RPC-client工作流程如下: 1. **业务代码发起异步RPC调用**:`Add(Obj1, Obj2, callback)`,此时不会阻塞调用线程,而是立即返回。 2. **序列化组件**:将`Obj1`和`Obj2`序列化为字节流,准备发送...
总结起来,Java中的回调机制主要通过接口实现,它提供了异步编程、事件处理和解耦组件的能力。这个“Java简单的回调(interface)demo”提供了一个基础的示例,展示了如何使用回调接口在任务完成时执行自定义操作。...
在Java中,回调方法的使用是实现可扩展性和解耦的关键技术之一。 通过分析提供的压缩包文件名称`callBack`,我们可以推测其中可能包含了示例代码或者测试用例,展示了上述回调方法的使用。进一步研究这些文件将有助...
大作业异步回调---马克-to-win Java视频到的详细描述与介绍
总结起来,Java自定义回调函数是实现异步编程和事件驱动的关键,通过接口定义和实现,我们可以创建灵活的代码结构,使得组件之间能够更好地协作,提高代码的复用性和可维护性。在Android和SDK开发中,理解和熟练运用...
在Java编程中,回调函数是一种设计模式,它允许我们在代码执行过程中插入自定义的行为,特别是在异步编程或者事件处理中非常常见。回调函数的核心思想是将一个函数作为参数传递给另一个函数,然后在适当的时候由被...
在本示例"CallBack_DEMO"中,我们可能正在探讨如何在Java或其他编程语言中实现回调机制。回调通常与异步编程相关,尤其是在处理I/O操作、网络请求或者时间事件时,它能让程序在执行完成后继续执行后续操作,而不是...
在Java编程中,接口回调是一种常见的设计模式,用于实现异步操作或者事件处理。当我们谈论“Java接口回调”时,核心思想是:一个类通过实现特定接口,将自身的某个方法暴露给其他对象调用,当特定事件发生或任务完成...
异步回调常常与Java的并发库(如`ExecutorService`,`Future`,`CompletableFuture`等)结合,或者在网络编程中的`Socket`和`ServerSocket`,它们都支持注册回调以处理接收到的数据或连接请求。 回调机制在Java中的...
本话题将深入探讨如何在Android中使用JNI进行多线程编程,并实现native方法对Java函数的回调。 1. **JNI基础知识**: - JNI是Java平台的一部分,为Java应用程序提供了与本地代码交互的能力。开发者可以通过JNI在...
Callback是最原始的异步处理方式,通过为被调用函数设置回调函数,当被调用函数执行完成后,调用这个回调函数来处理结果。这种方式的缺点是控制权反转,增加了代码的复杂性。 Java中使用Future来处理异步操作,但它...
回调技术(Callback)是软件设计模式中的一种,它在异步编程或事件驱动编程中扮演着重要角色。回调函数是一种代码执行模式,允许一个函数或方法在特定事件发生时被另一个函数调用。这种机制使得程序能够以非阻塞的...
基于回调实现Java的异步调用 异步调用是指调用发出后,调用者不会立刻得到结果,而是在调用发出后,被调用者通知调用者,或通过回调函数处理这个调用。回调简单地说就是B中有一个A,这样A在调用B的某个方法时实际...