java - 线程限制超出替换阻塞的工作线程

Question

我正在使用 AsyncHttpClient ，并并行发出许多 http 请求。我收到以下错误:

java.util.concurrent.RejectedExecutionException: Thread limit exceeded replacing blocked worker

如何让新请求等待直到有空闲线程？

我的代码:

public class MyClass {
    private AsyncHttpClient asyncHttpClient = new DefaultAsyncHttpClient();

    public JSONObject jsonFromUrl(String requestUrl) {
        CompletableFuture<Response> futureResponse = asyncHttpClient.prepareGet(requestUrl).
                addHeader("header-name", "header-value").execute().toCompletableFuture();
        try {
            Response response = futureResponse.get();
            ... handling response
        } catch (Exception e) {
            ... handling exception
        }
    }
}

Answer 1

您可以为处理被拒绝任务的线程池实现并设置一个RejectedExecutionHandler，将它们添加到执行器的工作队列中。

http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/RejectedExecutionHandler.html

threadPoolExecutor.setRejectedExecutionHandler(new RejectedExecutionHandler() {
    @Override
    public void rejectedExecution(Runnable task, ThreadPoolExecutor executor) {
        try {
            executor.getQueue().put(task);
        } catch (InterruptedException e) {
            // handle exception
        }
    }
});

请注意，在上面的实现中，put() 是一个阻塞操作，这意味着如果队列已满，它会等待直到有空间再次插入任务。