Как переназначить объекты для пула с пулом?

Question

В a simple test case я реализовал объединенный сервер потоков на прием до 10 одновременных входящих соединений TLS-PSK на порту 12345 и печать расшифрованы данные на стандартный вывод:

public static void main(String[] args) throws IOException { 
    ServerSocket server = new ServerSocket(12345); 
    ExecutorService pool = Executors.newFixedThreadPool(10); 

    while (true) { 
     Socket socket = server.accept(); 
     pool.execute(new MyRunnable(socket)); 
    } 
} 

Вот является Runnable реализация используется нитей:

@Override 
public void run() { 
    try { 
     SecureRandom random  = new SecureRandom();  // How to preallocate? 
     BufferedInputStream bis = new BufferedInputStream(mSocket.getInputStream()); 
     BufferedOutputStream bos = new BufferedOutputStream(mSocket.getOutputStream()); 
     TlsServerProtocol proto = new TlsServerProtocol(bis, bos, random); 
     MockPSKTlsServer server = new MockPSKTlsServer(); // How to preallocate? 
     proto.accept(server); 
     Streams.pipeAll(proto.getInputStream(), System.out); 
     proto.close(); 
    } catch (IOException e) { 
     System.err.print(e); 
    } 
} 

Как предопределить SecureRandom и MockPSKTlsServer объекты, используемые Runnable?

I.e. как создать 10 из обоих объектов в main(), а затем просто повторно использовать их в run()?

Answer 1

в вашем случае я хотел бы использовать ThreadLocal для каждого класса (SecureRandom и MockPSKTlsServer), чтобы иметь один выделенный экземпляр SecureRandom и MockPSKTlsServer для каждого потока вашего пула соединений и использовать их, когда нити должен выполнить тот же тип задачи, но с другим входом Socket, что-то вроде:

private static final ThreadLocal<SecureRandom> random = ThreadLocal.withInitial(
    SecureRandom::new 
); 
private static final ThreadLocal<MockPSKTlsServer> server = ThreadLocal.withInitial(
    MockPSKTlsServer::new 
); 

... 
public void run() { 
    try (BufferedInputStream bis = new BufferedInputStream(mSocket.getInputStream()); 
     BufferedOutputStream bos = new BufferedOutputStream(mSocket.getOutputStream()); 
     TlsServerProtocol proto = new TlsServerProtocol(bis, bos, random.get())) { 
     // Calling server.get() will get the instance dedicated to the current 
     // thread, if no instance exists so far for this thread 
     // new MockPSKTlsServer() will automatically be called then 
     // affected to this thread for subsequent get's calls 
     proto.accept(server.get()); 
     ... 
    } catch (IOException e) { 
     System.err.print(e); 
    } 
} 

NB: Используйте try-with-resources заявление автоматически закрыть ввода/вывода потоков.

Answer 2

Обычно я использовал бы ThreadLocal<> и использовал легкий класс Pool<T> для хранения и предоставления экземпляров.

Я не думаю, что есть Pool<T> из коробки, но это тривиально построено.

Единственное соображение с ThreadLocal<> - вы должны убедиться, что правильно отпустили обратно до Pool<>. Поэтому, если вы думаете об обмене этого с другим потоком, лучшим подходом может быть статический пул, который является общим, но с блокировкой (если вы не слишком заботитесь о производительности) или параллельным контейнером, если вы это сделаете.

Сказав, что: http://commons.apache.org/proper/commons-pool/