new Thread(new Runnable() {
public void run() {
.............
.............
.............
}
}).start();
如果我将在 main 中执行此操作,它将创建一个新线程并向其提交一个任务以进行异步计算。
如果您看到 FutureTask文档,它还会显示:
可取消的异步计算。此类提供 Future 的基本实现,包括启动和取消计算、查询计算是否完成以及检索计算结果的方法。
那么它如何FutureTask
在asynchronous computation
内部创建线程并提交我们在实例化时给它的任务,FutureTask
例如:
FutureTask f = new FutureTask(new MyCallable());
否则它不能是异步计算,请提供FutureTask
源代码 中的代码片段,它将任务提交给线程,使其成为异步计算。谢谢。
我得到了答案。它基本上是试图在与调用者相同的线程中运行任务。在给定的代码中非常明显:
当您调用futureTask.run()
它时,它只是调用sync.innerRun();
并且sync
是内部类的实例Sync
。因为它只是调用call()
同一线程中的可调用对象。
void innerRun() {
if (!compareAndSetState(READY, RUNNING))
return;
runner = Thread.currentThread(); //here it is getting the current thread
if (getState() == RUNNING) {
V result;
try {
result = callable.call();//here calling call which executes in the caller thread.
} catch (Throwable ex) {
setException(ex);
return;
}
set(result);
} else {
releaseShared(0); // cancel
}
}