执行器服务线程

Question

我有一个REST Webservices通过socket调用从遗留系统获得结果来处理它的请求。

因为有4个套接字可用，所以我设置了一个ExecutorService，其中没有4个线程来排队等待这样的连接。服务最初运行正常，但过了一段时间后性能开始下降；我使用jconsole并发现它正在创建>3000个线程，最后以以下错误结束：

SEVERE: Servlet.service() for servlet [jersey-serlvet] in context with
path [/DCardServices] threw exception [java.lang.OutOfMemoryError:
unable to create new native thread] with root cause
java.lang.OutOfMemoryError: unable to create new native thread

null

ExecutorService spool = Executors.newFixedThreadPool(Integer.valueOf(GlobalUtils.getAppProp().getString("socketPoolSize")).intValue());  
ExecutorService executorService = Executors.newFixedThreadPool(4);

public Response queforTdmProcess(JSSigData jsData) {
    return sndWSResponse(jsData.processCardResp1(executorService.submit(new TdmSocketRequest(jsData,socketQueue, spool)).get()));
}

public class TdmSocketRequest implements Callable<String>  {
    Socket s = getSocketFromPool();
    /* connection to socket and get data */
    retSocketToPool(s);
}


public Socket getSocketFromPool() {
    try {
        conSocketConsumer sckconsumer = new conSocketConsumer(getSocketQueue());
        Future<Socket> future = getSpool().submit(sckconsumer); 
        Socket s = future.get();
        System.out.print("Getting socket " +  s.getLocalPort() + " from the pool"  + "\n");

            return s;
        } catch (Exception e) {
            // TODO: handle exception
        }
        return null;
    }

public void retSocketToPool(Socket s) {
        conSocketProducer sckProducer = new conSocketProducer(getSocketQueue(),s);
        System.out.print("Returning socket " +  s.getLocalPort() + " to the pool" + "\n" );
        getSpool().submit(sckProducer);
    }
}

非常感谢您的任何建议和帮助！

Answer 1

executors.newfixedthreadpool（integer.valueof（globalutils.getappprop（）.getstring（“socketpoolsize”））.intvalue（））；

这一行使JVM创建integer.valueOf（globalutils.getAppprop().getString（“socketpoolsize”）.intvalue()线程。套接字池往往表示它可以创建的连接数量，通常在2000-3000之间。您不应该创建这种大小的线程池。

查看代码的其余部分，我不完全确定您试图用这个池做什么。您在新线程中创建套接字，但随后阻止在原始线程上检索这些套接字。我建议您删除所有添加的线程，因为目前它除了添加更多的线程之外什么也不做。

最后，在使用异步处理时，使用future.get()几乎总是一个坏主意，因为这会抵消多线程的任何好处。必须使用它表明您需要重新考虑您的设计。