在一个Servlet中同时处理

Question

我有一个Servlet，它接收请求，必须处理5个任务（从外部服务器获取数据），并将所有数据发送回客户机。

Answer 1

5秒太长了，它可能会占用web服务器资源，你可以让客户端发送一个请求a，这会触发你的5秒任务，但它不等待，立即返回。因为你知道这需要5秒钟，所以你可以在5秒钟后发送另一个请求B来获取数据。如果数据尚未准备好，您可以在另外5秒后请求，直到达到最大重试次数（由您自己定义）。

Answer 2

另一个选项是ExecutorService。有各种可用的示例，包括以下内容：

• 如何使用ExecutorService等待所有线程完成？
• ExecutorService，如何等待所有任务完成

以下是从上面找到的第一个链接中获取的一些示例代码：

ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
while(...) {
  taskExecutor.execute(new MyTask());
}
taskExecutor.shutdown();
try {
  taskExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
} catch (InterruptedException e) {
  ...
}

Answer 3

您可以使用CoundDownLatch

一种同步辅助工具，允许一个或多个线程等待，直到在其他线程中执行的一组操作完成。

示例代码：

    CountDownLatch startSignal = new CountDownLatch(1);
    CountDownLatch doneSignal = new CountDownLatch(5); // 5 tasks

    class Worker implements Runnable {
        private final CountDownLatch startSignal;
        private final CountDownLatch doneSignal;
        private final int threadNumber;

        // you can pass additional arguments as well
        Worker(CountDownLatch startSignal, CountDownLatch doneSignal,
                                                   int threadNumber) {
            this.startSignal = startSignal;
            this.doneSignal = doneSignal;
            this.threadNumber = threadNumber;
        }

        public void run() {
            try {
                startSignal.await();
                doWork(); // actual work to be performed here    
                doneSignal.countDown();
            } catch (InterruptedException ex) {
                LOGGER.error(ex);
            }
        }
    }

    // 5 new threads are started
    for(int i=1;i<=5;i++){
        new Thread(new Worker(startSignal, doneSignal, i)).start();
    }

    startSignal.countDown(); // let all threads proceed
    try {
        doneSignal.await(); // wait for all to finish
        // all 5 tasks are finished and do whatever you want to do next
    } catch (InterruptedException interruptedException) {
        LOGGER.error(interruptedException);
    }

阅读更多...并查找更多示例...