Java:newFixedThreadPool大小为5,出现pool-2-thread-6怎么回事?

发布于 2022-09-06 21:04:34 字数 293 浏览 17 评论 0

程序中

ExecutorService FIXED_THREAD_POOL = Executors.newFixedThreadPool(5);

用这个线程池,程序之前还只是有有pool-2-thread-1 - pool-2-thread-5, 但是有一天突然出现了一个pool-2-thread-6,而且只出现一次,很神奇,请问这是怎么回事?不是最多只有5个线程吗?

ps:线程是java业务逻辑,逻辑里执行主要是对数据入库,删数据项操作,很多数据库I/O很耗时,几十分钟几个小时啥的。

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

隐诗 2022-09-13 21:04:34

参考官方文档

public static ExecutorService newFixedThreadPool(int nThreads)

创建一个线程池, 在重用共享无界队列中运行的固定线程数。在任何时候, nThreads 个线程都将是活动的处理任务。如果在所有线程都处于活动状态时提交了其他任务, 则它们将在队列中等待, 直到线程可用为止。如果由于在关闭前执行过程中出现故障而终止了任何线程, 则如果需要执行后续任务, 则新项将取代它。池中的线程将存在, 直到显式关闭为止。

可以用下面的程序测试

import java.util.concurrent.Executors;
import java.util.concurrent.ExecutorService;

public class ThreadPoolTest1 {
    
    static class MyTask implements Runnable {
        private String name;
        
        public MyTask(String name){
            this.name = name;
        }

        
        @Override
        public void run() {
            for (int i = 0; i < 2; i++) {
                // 做点事情
                try {
                    Thread.sleep(100);
                    if(System.currentTimeMillis() % 3 == 0 ){
                         System.out.println("stop!");
                         throw  new RuntimeException("break!"); //(1)注释掉这一行将只有两个Thread!
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(name + " said:" + i+" Thread="+Thread.currentThread().getName());
            }
        }
    }

    
    public static void main(String[] args) {
        // 创建线程池
//        ExecutorService threadPool = Executors.newSingleThreadExecutor();
        ExecutorService threadPool = Executors.newFixedThreadPool(2);
//        ExecutorService threadPool = Executors.newCachedThreadPool();

        
        // 向线程池里面扔任务
        for (int i = 0; i < 10; i++) {
            threadPool.execute(new MyTask("Task" + i));
        }

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

注释掉(1)处的异常会得到正常结果

Task0 said:0 Thread=pool-1-thread-1
Task1 said:0 Thread=pool-1-thread-2
Task0 said:1 Thread=pool-1-thread-1
Task1 said:1 Thread=pool-1-thread-2
Task2 said:0 Thread=pool-1-thread-1
Task3 said:0 Thread=pool-1-thread-2
Task2 said:1 Thread=pool-1-thread-1
Task3 said:1 Thread=pool-1-thread-2
......

任务将在thread 1和2之间切换
抛出异常RuntimeException会看到如下的情况:

.......
java.lang.RuntimeException: break!
    at ThreadPoolTest1$MyTask.run(ThreadPoolTest1.java:22)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
Task4 said:0 Thread=pool-1-thread-5
Task5 said:0 Thread=pool-1-thread-6
......

能看到线程池在不断创建新的线程.

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文