●介绍
有时候执行一个任务需要很长时间,单线程下线程会处于阻塞状态。这个时候我们会考虑一种非阻塞的处理模式。非阻塞任务在任何编程语言里都必不可少,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版本。
代码public class Demo { public static void main ( String args []) { Value v = new Value (); v . setSum( 0 ); v . getSUM(); for ( int i = 0 ; i < 100 ; i ++ ) { System . out .... } while (v ....
大作业异步回调---马克-to-win Java视频到的详细描述与介绍
* 同步回调public void goToPrintSyn(Callback callback, String text) {* 异步回调public voi
回调函数(callback Function),顾名思义,用于回调的函数。 回调函数只是一个功能片段,由用户按照回调函数调用约定来实现的一个函数。回调函数是一个工作流的一部分,由工作流来决定函数的调用(回调)时机。回调...
最近学习java,接触到了回调机制(CallBack)。初识时感觉比较混乱,而且在网上搜索到的相关的讲解,本文介绍了Java的回调机制,有兴趣的同学可以了解一下。
Jquery核心之一 ajax: 1. load(url,[data],[callback])载入远程HTML文件代码... Callback(callback):(可选参数)请求完成是(不需要是success的)的回调函数 $(“.ajax.load”).load(“http://www.cnblogs.com”)
3.按照企微规范定义controller的接收值,能实现企微代开发回调的GET校验,POST传值,快速响应,异步处理。 4.按照企微规范实现回调数据的验签解析。开发人员只需要注重自己的业务代码。 4.按照企微规范提供丰富的...
API是用于Java异步编程的高级API。 该API支持将多个异步计算流水线化(也称为链接或合并)成单个结果,而不会造成嵌套回调(“ callback hell”)的混乱。 此API也是Java中Future / Promise并发构造的实现。 从Java ...
回调函数定义 回调函数就是一个通过函数指针调用的函数。如果你把函数的指针(地址)作为参数传递...因此callback 不一定用于异步,一般同步(阻塞)的场景下也经常用到回调,比如要求执行某些操作后执行回调函数。 例子
回调模式 建造者模式 单例模式 我能做什么 : 可以从系统直接创建日期 可以从给定日期创建日期 你可以把任何地方放在你想要的字符串中 段落 句子 网页 任何 如果需要,可以自定义您的日期 您可以使用 MarkDown {DATE...
本文实例讲述了javascript带回调函数的异步脚本载入方法。分享给大家供大家参考。具体实现方法如下: var Loader = function () { } Loader.prototype = { require: function (scripts, callback) { this....
除此之外,通常很麻烦的Java回调接口,你很快就会陷入意大利面条代码(恰当地称为“Callback Hell”)。 无论您使用多少编码模式来避免这种情况,您都必须以一种方式遇到多个线程的状态更改。 创建响应式应用程序的...
第一种实现(来源网上转贴): ... //调用Java类Test的getString方法,callBackFun为回调函数 JTest.getString(function(data){_data = data;} //重新设置为异步方式 DWREngine.setAsync(true); return _data; }
异步执行可以用回调函数实现: function callback() { console.log('Done'); } console.log('before setTimeout()'); setTimeout(callback, 1000); // 1秒钟后调用callback函数 console.log('after setTimeout()'...
这里仅仅是定义了Converter并且简单的放在….>元素之内,任何的….>元素内容都有两个必须定义的属性.一个是对converter定义的引用和converter能够转换的类. 例如最简单的converter是null converter,它作用是把null和...
阿里云图片/视频审核支持同步检测和异步检测两种方式。...异步检测需要您轮询结果或者通过callback回调通知获取检测结果。 图片/视频支持传入互联网图片URL、本地图片文件路径以及二进制图片文件流。
回调函数是异步编程最基本的方式。 采用这种方式,我们把同步操作变成了异步操作,主函数不会堵塞程序运行,相当于先执行程序的主要逻辑,将耗时的操作推迟执行。 回调函数的优点是简单、容易理解和部署,缺点是不...
所谓异步执行,不同于同步执行(程序的执行顺序与任务的排列顺序是一致的、同步的),每一个任务有一个或多个回调函数(callback),前一个任务结束后,不是执行后一个任务,而是执行回调函数,后一个任务则是不等前...
那么问题来了,在编写node的时候,会在后台去请求很多接口(我们公司是与java后台交接数据的),接口就会有个回调,这么多回调怎么办呢……每个回调回来的加载顺序怎么去处理是个问题……总不可能去嵌套……嵌套……...