每个线程都有资源的Java FixedThreadPool？

Question

这是我当前工作代码的伪代码版本：

public class DataTransformer {
    private final boolean async = true;
    private final ExecutorService executorService = Executors.newSingleThreadExecutor();

    public void modifyAsync(Data data) {
        if (async) {
            executorService.submit(new Runnable() {
                @Override
                public void run() {
                    modify(data);
                }
            });
        } else {
            modify(data);
        }
    }

    // This should actually be a variable inside modify(byte[] data)
    // But I reuse it to avoid reallocation
    // This is no problem in this case
    // Because whether or not async is true, only one thread is used
    private final byte[] temp = new byte[1024];

    private void modify(Data data) {
        // Do work using temp
        data.setReady(true); // Sets a volatile flag
    }
}

请阅读 cmets。但现在我想使用Executors.newFixedThreadPool(10) 而不是Executors.newSingleThreadExecutor()。在我的情况下，这很容易通过将字段temp 移动到modify(Data data) 中来实现，这样每次执行都有自己的temp 数组。但这不是我想做的，因为我想尽可能重用数组。相反，我希望 10 个线程中的每一个线程都有一个 temp 数组。实现这一目标的最佳方法是什么？

Answer 1

由于static 变量在所有线程之间共享，因此您可以声明为静态。但是如果你想使用不同的值，那么要么使用 Threadlocal 要么使用不同的对象。

使用 ThreadLocal 你可以做到：

  ThreadLocal<byte[]> value = ThreadLocal.withInitial(() -> new byte[1024]);

你也可以像这样使用对象：

public class Test {

public static void main(String[] args) {
    try {
        Test test = new Test();
        test.test();
    } catch (Exception e) {
        e.printStackTrace();
    }

}
class Control {
    public volatile byte[] temp = "Hello World".getBytes();
}
final Control control = new Control();

class T1 implements Runnable {
    @Override
    public void run() {
        String a = Arrays.toString(control.temp);
        System.out.println(a);
    }
}
class T2 implements Runnable {
    @Override
    public void run() {
        String a = Arrays.toString(control.temp);
        System.out.println(a);
        }
    }
private void test() {
    T1 t1 = new T1();
    T2 t2 = new T2();

    new Thread(t1).start();
    new Thread(t2).start();
}
}