ExecutorService在Java Web应用中的使用案例

在Java Web应用中，ExecutorService是一个用于管理和控制线程执行的框架。它提供了一种将任务提交给线程池进行异步执行的方法。以下是一个简单的使用案例：

1. 首先，创建一个实现Runnable接口的类，该类将包含要在后台执行的任务：

public class MyTask implements Runnable {
    private String taskName;

    public MyTask(String taskName) {
        this.taskName = taskName;
    }

    @Override
    public void run() {
        System.out.println("Executing task: " + taskName);
        try {
            // 模拟任务执行耗时
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Task completed: " + taskName);
    }
}

2. 在Web应用的Servlet或Controller中，创建一个ExecutorService实例，并将任务提交给线程池执行：

import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet("/MyServlet")
public class MyServlet extends HttpServlet {
    private static final long serialVersionUID = 1L;
    private ExecutorService executorService;

    @Override
    public void init() throws ServletException {
        super.init();
        // 创建一个固定大小的线程池
        executorService = Executors.newFixedThreadPool(5);
    }

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        for (int i = 0; i < 10; i++) {
            // 创建任务并提交给线程池执行
            MyTask task = new MyTask("Task-" + i);
            executorService.submit(task);
        }

        // 关闭线程池
        executorService.shutdown();
    }
}

在这个例子中，我们创建了一个固定大小为5的线程池，并在doGet方法中提交了10个任务。这些任务将在不同的线程中并发执行。当所有任务完成后，我们调用executorService.shutdown()方法关闭线程池。