线程池在Java中的应用实践

news2024/11/18 15:44:04

摘要：在实际业务场景中，线程池发挥着重要作用。本文将详细解答在高并发、任务执行时间短、并发不高、任务执行时间长以及并发高、业务执行时间长的业务场景下，如何使用线程池进行优化。

一、高并发、任务执行时间短的业务场景

在高并发、任务执行时间短的业务场景中，我们可以使用Executors.newCachedThreadPool()创建一个可缓存线程池。这种线程池会根据业务需求灵活回收空闲线程，当线程池长度超过处理需要时，会新建线程。示例：

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
for (int i = 0; i < 10; i++) {
    final int index = i;
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    cachedThreadPool.execute(new Runnable() {
        public void run() {
            System.out.println(index);
        }
    });
}

二、并发不高、任务执行时间长的业务场景

在并发不高、任务执行时间长的业务场景中，我们可以使用Executors.newFixedThreadPool()创建一个定长线程池。这种线程池可以控制线程的最大并发数，当超过线程池最大并发数时，任务会在队列中等待。示例：

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
for (int i = 0; i < 10; i++) {
    final int index = i;
    fixedThreadPool.execute(new Runnable() {
        public void run() {
            System.out.println(index);
        }
    });
}

三、并发高、业务执行时间长的业务场景

在并发高、业务执行时间长的业务场景中，我们可以使用Executors.newScheduledThreadPool()创建一个定长线程池。这种线程池支持定时及周期性任务执行。示例：

ExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(2);
ScheduledFuture<?> future = scheduledThreadPool.scheduleAtFixedRate(new Runnable() {
    public void run() {
        System.out.println("Long-running task");
    }
}, 0, 10, TimeUnit.SECONDS);

四、并发高、业务执行时间长的业务场景

在并发高、业务执行时间长的业务场景中，我们可以使用Executors.newSingleThreadExecutor()创建一个单线程化的线程池。这种线程池只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序（FIFO，LIFO，优先级）执行。示例：

ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
singleThreadExecutor.execute(new Runnable() {
    public void run() {
        System.out.println("Long-running task");
    }
});