如何在线程运行时修改变量

Question

起初，我使用 Runnable 并构建了一个“while(true)”循环来继续处理我的工作。 现在我在改用 Callable 时发现了一些困难。

package com;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class CallableAndFuture {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ChildCallbale childCallbale = new ChildCallbale();
        FutureTask<Integer> future = new FutureTask<Integer>(childCallbale);
        Thread thread = new Thread(future);
        thread.start();
        childCallbale.setVar(1);
        System.out.println(future.get());
        childCallbale.setVar(2);
        System.out.println(future.get());
    }
}
class ChildCallbale implements Callable<Integer>{
    private int var;

    public void setVar(int var){
        this.var = var;
    }
    @Override
    public Integer call() throws Exception {
        Thread.sleep(2000);
        return var;
    }
}

如您所见，我希望得到不同的结果。不幸的是，2 个结果等于 1。 我不仅想知道如何实现我的要求，我还想知道我的代码不正确的原因。提前致谢。

Answer 1

future 的get() 方法等待计算完成。所以它会等待你的线程休眠两秒钟。然后结果为 1。结果保持为 1，因为线程没有重新运行（也不应该重新运行！）。

所以第二个setVar 对结果没有影响。