Java并发编程：线程池和定时任务的应用实例-蒲公英云

Java并发编程：线程池和定时任务的应用实例

原创电玩女神 2024-12-11 19:36 80阅读 0赞

在Java并发编程中，线程池和定时任务是两种常用的管理和调度方式。下面我们将通过实际的代码示例来解释这两种技术的应用。

线程池

线程池是一种预先创建好一定数量线程，并将这些线程存储在一个共享的容器中的机制。使用线程池可以避免频繁创建和销毁线程带来的性能开销。

以下是一个简单的Java线程池应用实例：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);
        // 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            final int taskIndex = i;
            executor.submit(() -> {
                System.out.println("Task " + taskIndex + " is running by thread: " + Thread.currentThread().getName());
                // 这里是任务执行逻辑，可以根据需要实现
                try {
                    Thread.sleep(1000); // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + taskIndex + " completed by thread: " + Thread.currentThread().getName());
            });
        }
        // 关闭线程池，释放资源
        executor.shutdown();
        while (!executor.isTerminated())) {
            try {
                Thread.sleep(100); // 等待一段时间防止干扰
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("All threads in the pool have completed.");
    }
}

这个例子展示了如何创建一个固定大小的线程池，然后提交任务到线程池中。当所有任务执行完毕后，关闭线程池释放资源。

定时任务

Java中的java.util.concurrent包提供了ScheduledExecutorService来实现定时任务。以下是一个简单的定时任务应用示例：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class DelayedTaskExample {
    public static void main(String[] args) {
        // 创建一个单线程的ScheduledExecutorService实例
        ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
        // 提交一个延迟1秒执行的任务到线程池
        executor.schedule(() -> {
            System.out.println("Delayed task executed after a delay of 1 second.");
        }, 1, TimeUnit.SECONDS));
        // 关闭ScheduledExecutorService以释放资源
        executor.shutdown();
    }
}