Java 线程休眠

Question

我有一个主 for 循环，可以向外部系统发送请求。外部系统可能需要几秒钟甚至几分钟才能做出响应。
此外，如果请求数达到 MAX_REQUESTS，当前的 for 循环应该 SLEEP 几秒钟。

这是我的场景。假设主 for 循环进入休眠状态 5 秒，因为它已达到 MAX_REQUESTS。然后说以前的外部请求从 callExternalSystem() 返回。当前处于 SLEEP 状态的主 for 循环线程会发生什么？它会被中断并继续处理还是继续 SLEEP？

for(...){
  ...
  while(numRequestsProcessing > MAX_REQUESTS){
     Thread.sleep(SLEEP_TIME);
  }
  ...
 callExternalSystem();

}

提前致谢。

Answer 1

一种方法是使用 ThreadPoolExecutor，只要没有空闲线程就会阻塞。

ThreadPoolExecutor executor = new ThreadPoolExecutor(MAX_REQUESTS, MAX_REQUESTS, 60, TimeUnit.SECONDS, new SynchronousQueue<Runnable>(), new RejectedExecutionHandler() {
    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        try {
            executor.getQueue().offer(r, Long.MAX_VALUE, TimeUnit.NANOSECONDS);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
});
for(int i=0;i<LOTS_OF_REQUESTS;i++) {
    final int finalI = i;
    executor.submit(new Runnable() {
        @Override
        public void run() {
            request(finalI);
        }
    });
}

另一种方法是让任务生成自己的请求。这样，每次线程同时空闲时都会生成一个新请求。

ExecutorService executor = Executors.newFixedThreadPool(MAX_REQUESTS);
final AtomicInteger counter = new AtomicInteger();
for (int i = 0; i < MAX_REQUESTS; i++) {
    executor.submit(new Runnable() {
        @Override
        public void run() {
            int i;
            while ((i = counter.getAndIncrement()) < LOTS_OF_REQUESTS)
                request(i);
        }
    });
}

Answer 2

我会使用 java.util.concurrent.Executors 创建一个具有 MAX_REQUESTS 线程的线程池。为您一次发送的多个请求创建一个 java.util.concurrent.CountDownLatch。将锁存器传递给发出请求的 Runnable，它们在完成时在锁存器上调用 countDown()。然后主线程在闩上调用 await(timeout)。我还推荐《Java Concurrency in Practice》一书。

Answer 3

除非您有一些代码可以中断正在休眠的线程，否则它将继续休眠直到所需的时间过去。如果您不希望这种情况发生，您可以使用wait()/notify() 而不是sleep()，以便另一个线程可以通知对象主线程正在休眠，以便唤醒它。当然，这依赖于存在另一个线程来注意到外部系统已响应 - 尚不清楚您如何获得响应。

编辑：听起来你真的应该使用Semaphore。每次主线程想要发出请求时，它都会获得一个许可。每次有响应时，都会释放许可证。然后，您只需要根据需要设置并发请求的数量即可。如果您希望能够在主线程中指定超时，请使用 tryAcquire - 但请考虑如果您已经有许多您真正满意的未完成请求，您想要做什么。