用Java调用一个异步方法时,方法会马上返回,而结果会在之后再去取
例如:
javapublic void invoke(Runnable task) {
threadPool.execute(task);
}
//或者
public Future submit(Callable task) {
return threadPool.submit(task);
}
以上方法都是异步的,对于需要得到返回结果的,可以通过future.get()来取得结果。
我的问题是:
如果一个方法一开始是异步的,我想把它转成同步来用,应该做哪些修改,或者是添加哪些类和逻辑?
Java中的异步转同步有没有哪些一般的编程模式?据说用CountDownLatch也可以实现异步转同步,但我还不太理解。
等待各位解答,先谢谢!
public synchronized TIMMessage queryLatestMessage(TIMConversation conversation) throws InterruptedException { final CountDownLatch latch = new CountDownLatch(1); final List<TIMMessage> typeMessages = new ArrayList<>(); conversation.getMessage(1, null, new TIMValueCallBack<List<TIMMessage>>() { @Override public void onError(int code, String desc) { latch.countDown(); } @Override public void onSuccess(List<TIMMessage> msgs) { TIMMessage msg0 = null; if (msgs.size() < 1) { return; } for (TIMMessage msg : msgs) { if (msg.status() != TIMMessageStatus.HasDeleted) { typeMessages.add(msg); break; } } latch.countDown(); } }); latch.await(); if (typeMessages.size() > 0) { return typeMessages.get(0); } else { return null; } }
Guava 有一个ListenableFuture 可以看看http://www.cnblogs.com/hupengcool/p/3991310.html
异步转同步一般思路就是轮询, 等待线程一直查询一个bool变量值, 执行线程在任务结束时候设置为bool为true, 这样等待线程接着就可以向下执行了