java - java thread pools and variable parameters

Question

Here is my code :

final int g = 0;

ExecutorService threadPool = Executors.newFixedThreadPool(10);
for (int i = 0; i < 10; i++) {
    threadPool.submit(new Runnable() {
        public void run() {
            g++;
            myFunc(g);
        }
    });
}

Obviously this doesn't work because of concurrent access on the variable g.

I've tried a lot of things, but didn't manage to find a nice and easy way to fix it. Any solutions ?

Thanks.

Answer 1

この例では、gはプリミティブ定数であるため、変更することはできません。一方、Runnable実装からアクセスするには、定数である必要があります。それを変更したい場合は、AtomicIntegerのようなスレッドセーフクラスを使用する必要があります。

これを試して：

    final AtomicInteger g = new AtomicInteger()

    ExecutorService threadPool = Executors.newFixedThreadPool(10);
    for (int i = 0; i < 10; i++) {
        threadPool.submit(new Runnable() {
            public void run() {
                int local = g.incrementAndGet();
                myFunc(local);
            }
        });
    }

Answer 2

あなたの例では、の宣言をループに移動しg、forに割り当てiてfinal g、それをで使用することができrun()ます。

ExecutorService threadPool = Executors.newFixedThreadPool(10);
for (int i = 0; i < 10; i++) {
  final int g = i+1;
  threadPool.submit(new Runnable() {
    public void run() {
      myFunc(g);
    }
  });
}