iSouthJava 里 long 可以计数多久2015/09/20 - Posted By 起衣0 条评论Tags: java - Category: Code并发编程 Promise, Future 和 Callback2014/06/22 - Posted By 起衣1 条评论去除了对 EventLoop 的依赖，Callback 的执行策略不同：任务未完成时添加的 Callback，会在结束任务的线程执行；任务完成后添加的 Callback 会在添加 Callback 线程立即执行一个 Callback 执行后会立即被清理Callback 可以根据任务结果添加，支持添加以下三种 Callback: onComplete, onSuccess, onFailure, 不需要和 Netty 的 FutureListener 一样大部分场景下都需要检查 future.isSuccess 等支持 Callback 的组合，Callback 包含一些函数式的方法，比如 compose 和 andThen 可以用来组合使用 CountdownLatch 替换掉了 Netty 的 wait/notify 实现去掉 Netty Future 一些不常使用的方法，同时补充一些模型间关联的方法，比如 Promise.getFuture异步执行任务，获得 Future 后添加 Callbackfinal TaskPromise promise = new DefaultTaskPromise();final TaskFuture future = promise.getFuture();final CountDownLatch latch = new CountDownLatch(1);future.onComplete(new TaskCallback() { // 添加结束 Callback    @Override    public TaskFuture apply(TaskFuture f) {        latch.countDown();        return f;    }});new Thread(new Runnable() {    @Override    public void run() {        promise.setSuccess(null);    }}).start();latch.await();异步执行任务，获得 Future 后添加成功结束的 Callbackfinal TaskPromise promise = new DefaultTaskPromise();final TaskFuture future = promise.getFuture();final CountDownLatch latch = new CountDownLatch(1);future.onSuccess(new TaskCallback() { // 添加成功结束 Callback    @Override    public TaskFuture apply(TaskFuture f) {        latch.countDown();        return f;    }});new Thread(new Runnable() {    @Override    public void run() {        promise.setSuccess(null);    }}).start();latch.await();异步执行任务，获得 Future 后，添加失败结束的组合 Callbackfinal TaskPromise promise = new DefaultTaskPromise();final TaskFuture future = promise.getFuture();final CountDownLatch latch = new CountDownLatch(2);future.onFailure(new TaskCallback() {    @Override    public TaskFuture apply(TaskFuture f) {        latch.countDown();        return f;
    }
}.andThen(new TaskCallback() {
    @Override
    public TaskFuture apply(TaskFuture f2) {
        latch.countDown();
        return f2;
    }
}));
new Thread(new Runnable() {
    @Override
    public void run() {
        promise.setFailure(new IllegalStateException("cm"));
    }
}).start();
latch.await();
异步执行任务，获得 Future 后阻塞等待任务完成
final TaskPromise promise = new DefaultTaskPromise();
final TaskFuture future = promise.getFuture();
new Thread(new Runnable() {
    @Override
    public void run() {
        try {
            TimeUnit.SECONDS.sleep(2);
        } catch (InterruptedException e) {
        }
        promise.setFailure(new IllegalStateException("cm"));
    }
}).start();
future.await();
参考:
http://docs.scala-lang.org/sips/completed/futures-promises.html
http://scala-lang.org/
https://github.com/netty/netty
http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/CountDownLatch.html
http://biasedbit.com/countdownlatch-vs-wait-notify/
Tags: callback,java,未来 - Category: Code
golang 以 dom 方式解析 xml
2013/12/04 - Posted By 起衣
0 条评论
Tags: go