java实现线程池的几种方式

在Java中，实现线程池主要有以下几种方式：

1. 使用Executors工具类创建线程池：

   Java提供了Executors工具类，可以方便地创建不同类型的线程池。以下是几种常用的线程池创建方法：

   • 创建一个固定大小的线程池：

     ExecutorService executor = Executors.newFixedThreadPool(5);
     

   • 创建一个可缓存线程池：

     ExecutorService executor = Executors.newCachedThreadPool();
     

   • 创建一个单线程化的线程池：

     ExecutorService executor = Executors.newSingleThreadExecutor();
     

   • 创建一个定时线程池：

     ExecutorService executor = Executors.newScheduledThreadPool(5);
     

2. 使用ThreadPoolExecutor类创建线程池：

   ThreadPoolExecutor是Java提供的一个线程池实现类，可以通过继承该类并实现相应的方法来创建自定义的线程池。以下是创建线程池的基本步骤：

   • 定义线程池的核心线程数、最大线程数、线程空闲时间等参数。
   • 实现newTaskFor方法，用于将任务封装成Runnable或Callable对象。
   • 实现afterExecute方法，用于在线程完成任务后执行一些操作，如关闭线程等。
   • 创建ThreadPoolExecutor实例并调用execute或submit方法提交任务。

3. 使用第三方库：

   除了Java自带的线程池实现外，还可以使用一些第三方库来创建和管理线程池，如Apache Commons ThreadPool、Guava等。这些库通常提供了更丰富的功能和更灵活的配置选项。

以下是使用Apache Commons ThreadPool创建线程池的示例：

import org.apache.commons.pool2.BasePooledObjectFactory;
import org.apache.commons.pool2.PooledObject;
import org.apache.commons.pool2.impl.DefaultPooledObject;
import org.apache.commons.pool2.impl.GenericObjectPool;

public class ThreadPoolExample {
    public static void main(String[] args) {
        GenericObjectPool<Runnable> pool = new GenericObjectPool<>(new RunnableFactory());
        pool.setMaxTotal(5);
        pool.setMaxIdle(3);

        for (int i = 0; i < 10; i++) {
            pool.execute(() -> {
                System.out.println("Task executed by thread: " + Thread.currentThread().getName());
            });
        }

        pool.shutdown();
    }

    static class RunnableFactory extends BasePooledObjectFactory<Runnable> {
        @Override
        public PooledObject<Runnable> create() {
            return new DefaultPooledObject<>(new RunnableTask());
        }

        @Override
        public void passivateObject(PooledObject<Runnable> pooledObject) {
            // No-op
        }
    }

    static class RunnableTask implements Runnable {
        @Override
        public void run() {
            System.out.println("Task is running.");
        }
    }
}

总之，Java提供了多种创建和管理线程池的方式，可以根据实际需求和场景选择合适的方法。