Java

java threadpoolexecutor能自定义线程工厂吗

小樊
86
2024-11-16 23:24:55
栏目: 编程语言

是的,Java的ThreadPoolExecutor允许你自定义线程工厂。你可以通过实现ThreadFactory接口并重写newThread(Runnable r)方法来实现自定义线程工厂。然后,将这个自定义线程工厂传递给ThreadPoolExecutor的构造函数。

以下是一个简单的示例:

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class CustomThreadPoolExecutor {
    public static void main(String[] args) {
        // 创建一个自定义线程工厂
        ThreadFactory customThreadFactory = new ThreadFactory() {
            private final ThreadFactory defaultThreadFactory = Executors.defaultThreadFactory();
            private final AtomicInteger threadNumber = new AtomicInteger(1);

            @Override
            public Thread newThread(Runnable r) {
                // 自定义线程名称
                Thread t = defaultThreadFactory.newThread(r);
                t.setName("CustomThread-" + threadNumber.getAndIncrement());
                return t;
            }
        };

        // 使用自定义线程工厂创建一个线程池
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
                5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(20), customThreadFactory);

        // 提交任务到线程池
        for (int i = 0; i < 30; i++) {
            threadPoolExecutor.submit(() -> {
                System.out.println("Task executed by thread: " + Thread.currentThread().getName());
                try {
                    TimeUnit.SECONDS.sleep(2);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }

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

在这个示例中,我们创建了一个自定义线程工厂,它为每个新创建的线程设置了一个自定义名称。然后,我们使用这个自定义线程工厂创建了一个ThreadPoolExecutor实例,并提交了一些任务到线程池。

0
看了该问题的人还看了