Java并发编程：线程池实战案例

原创 Myth丶恋晨 2024-11-14 00:34 3阅读 0赞

Java并发编程中的线程池是一种执行器（Executor），用于在一个后台线程中执行任务。线程池的主要目的是减少在创建和销毁线程时所产生的性能开销。通过重用已经创建的线程来执行新的任务，线程池提高了程序的响应速度，并且提供了更好的系统资源管理。

以下是一些线程池的实战案例：

###1.固定大小的线程池```javaint nThreads =10; //线程池的大小ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);

for (int i =0; i <100; i++) {
 threadPool.execute(new Runnable() {
 public void run() {
//任务代码 }
 });
}

threadPool.shutdown(); //所有任务执行完毕后关闭线程池```###2.单线程的线程池```javaExecutorService threadPool = Executors.newSingleThreadExecutor();

for (int i =0; i <100; i++) {
 threadPool.execute(new Runnable() {
 public void run() {
//任务代码 }
 });
}

threadPool.shutdown();
```###3.可缓存的线程池```javaExecutorService threadPool = Executors.newCachedThreadPool();

for (int i =0; i <100; i++) {
 threadPool.execute(new Runnable() {
 public void run() {
//任务代码 }
 });
}

threadPool.shutdown();
```###4.定时及周期性任务的线程池```javaScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);

//延迟3秒后执行，之后每隔5秒执行一次scheduledThreadPool.scheduleAtFixedRate(new Runnable() {
 public void run() {
//任务代码 }
},3,5, TimeUnit.SECONDS);

//所有任务执行完毕后关闭线程池scheduledThreadPool.shutdown();
```###5.线程池监控```javaThreadPoolExecutor threadPool = new ThreadPoolExecutor(10,50,1, TimeUnit.MINUTES, new LinkedBlockingQueue<Runnable>());

// 提交任务for (int i =0; i <100; i++) {
 threadPool.execute(new Runnable() {
 public void run() {
//任务代码 }
 });
}

//监控线程池状态int activeCount = threadPool.getActiveCount();
long completedTaskCount = threadPool.getCompletedTaskCount();
int queueSize = threadPool.getQueue().size();

threadPool.shutdown();
```###6. 自定义线程工厂```javaThreadFactory threadFactory = new ThreadFactory() {
 private final AtomicInteger threadNumber = new AtomicInteger(1);

public Thread newThread(Runnable r) {
Thread t = new Thread(r, "My-Thread-" + threadNumber.getAndIncrement());
 return t;
 }
};

ExecutorService threadPool = Executors.newFixedThreadPool(10, threadFactory);

// 提交任务for (int i =0; i <100; i++) {
 threadPool.execute(new Runnable() {
 public void run() {
//任务代码 }
 });
}

threadPool.shutdown();
```在实际应用中，根据任务的特性和系统资源选择合适的线程池类型是非常重要的。例如，对于短生命周期的大量任务，使用可缓存的线程池可能更合适；而对于需要定时执行的任务，则可以使用定时及周期性任务的线程池。自定义线程工厂可以帮助我们更好地控制线程的创建和管理。