我需要在 Java 中建立一个工人池,其中每个工人都有自己的连接套接字;当工作线程运行时,它使用套接字但保持打开以供以后重用。我们之所以决定采用这种方法,是因为与在 ad-hoc 基础上创建、连接和销毁套接字相关的开销需要太多开销,因此我们需要一种方法,通过该方法,工作池可以通过其套接字连接进行预初始化,准备好在保持套接字资源不受其他线程影响的同时继续工作(套接字不是线程安全的),所以我们需要这些方面的东西......
public class SocketTask implements Runnable {
Socket socket;
public SocketTask(){
//create + connect socket here
}
public void run(){
//use socket here
}
}
在应用程序启动时,我们希望初始化工作程序,并希望以某种方式初始化套接字连接......
MyWorkerPool pool = new MyWorkerPool();
for( int i = 0; i < 100; i++)
pool.addWorker( new WorkerThread());
当应用程序请求工作时,我们将任务发送到工作池以立即执行......
pool.queueWork( new SocketTask(..));
使用工作代码更新
基于 Gray 和 jontejj 的有用评论,我有以下代码工作......
套接字任务
public class SocketTask implements Runnable {
private String workDetails;
private static final ThreadLocal<Socket> threadLocal =
new ThreadLocal<Socket>(){
@Override
protected Socket initialValue(){
return new Socket();
}
};
public SocketTask(String details){
this.workDetails = details;
}
public void run(){
Socket s = getSocket(); //gets from threadlocal
//send data on socket based on workDetails, etc.
}
public static Socket getSocket(){
return threadLocal.get();
}
}
执行服务
ExecutorService threadPool =
Executors.newFixedThreadPool(5, Executors.defaultThreadFactory());
int tasks = 15;
for( int i = 1; i <= tasks; i++){
threadPool.execute(new SocketTask("foobar-" + i));
}
我喜欢这种方法有几个原因......
- 套接字是可用于正在运行的任务的本地对象(通过 ThreadLocal),从而消除了并发问题。
- 套接字创建一次并保持打开状态,在新任务排队时重用,从而消除了套接字对象创建/销毁的开销。