我有点惭愧地问了这个基本的问题,但它在这里。
假设我有一个主类和一个工作线程。辅助线程执行一些异步工作,并将结果返回到主类的回调。
现在我正在挣扎的是:主类的回调是作为工作线程的一部分执行的。我已经做了十几次了,它从来没有给我带来任何问题,但我想知道如何优雅地将一个响应从工作线程返回到实际的主线程。
我知道我可以使用Future和FutureTask等,但我觉得很笨重。
示例:
class ThreadTest {
private Runnable mRunnable;
public ThreadTest() {
System.out.println("ThreadTest(): thread " + Thread.currentThread().getId());
mRunnable = new Runnable() {
public void run() {
System.out.println("run(): thread " + Thread.currentThread().getId());
print();
}
};
new Thread(mRunnable).start();
}
private void print() {
System.out.println("print(): thread " + Thread.currentThread().getId());
}
public static void main(String... args) {
System.out.println("main(): thread " + Thread.currentThread().getId());
ThreadTest t = new ThreadTest();
}
}输出:
main(): thread 1
ThreadTest(): thread 1
run(): thread 9
print(): thread 9我想要的是:
main(): thread 1
ThreadTest(): thread 1
run(): thread 9
print(): thread 1发布于 2017-01-31 07:45:09
此类问题的一个常见解决方案是在主线程和工作线程之间提供“通信通道”。
换句话说:在数据结构之间放置一个数据结构,一边可以写入,另一边可以读取。
实现这一目标的常见方法是使用ConcurrentLinkedQueue。有关进一步阅读,请参见here;包括一个简单的生产者/消费者场景。
除此之外,你应该更清楚你的设计。我的意思是:我要么专注于
换句话说:这可以看作是“拉”(使用未来)或“推送”(调用回调方法的线程B)。我建议决定一个概念,不要同时使用两个概念的"50%“!
发布于 2017-01-31 07:53:36
最不复杂的解决方案是使用wait()和notify()。
顺便提一句,我认为期货没有什么不妥之处,尤其是如果我们谈论的是java8和CompletableFuture。
https://stackoverflow.com/questions/41951964
复制相似问题