Java同步Executor Service池中线程之间的数据[重复]

Question

我正在尝试在几个线程（6）之间同步一个int计数器。下面是我的工人班。我正在尝试同步我的私有字段计数器测试：

public class DbWorker implements Callable {

    private final Object lock = new Object();
    private int countertest = 0 ;

    private  boolean  IsActive(Integer act)
    {
        synchronized(lock){ 
        boolean exists = false;
        countertest++;
            ....
       System.out.println("countertest  IS :  " + countertest );
         }
       return true;
    }

     public void run() {
        ....
        IsActive(act):
        ...
     }

}

在我的主类中，我使用 for 循环和执行器服务创建线程。请参阅以下内容：

private ExecutorCompletionService<Integer> _objQueue ;

 for(int j = 0; j < 6; j++){
     _objQueue.submit( new DbWorker( "SOME PARAMETER" , _snapshots.get(j) , j )    );
}

我的反测试变量不同步，它打印不同的数字(非顺序)。我做错了什么？

Answer 1

因为您在循环中创建了一个实例，其中antitest和lock是实例变量，因此每个对象都将获得一个新对象。

>

反测试在这种情况下始终为1，实例之间不共享

多个线程没有获得同一个锁，所以这是没有用的。

Answer 2

你的锁

private final Object lock = new Object();

是实例字段。换句话说，每个< code>DbWorker对象都有一个。

然后将DbWorker实例提交给执行

_objQueue.submit( new DbWorker( "SOME PARAMETER" , _snapshots.get(j) , j )    );

每个线程都有自己的< code>DbWorker，因此也有自己的锁。线程从不与任何其他线程竞争。

创建一个数据库工作线程并在线程之间共享它，即。每次都提交相同的数据库工作实例。