zoukankan      html  css  js  c++  java

  • 基于队列的线程池

    http://lavasoft.blog.51cto.com/62575/1542298

     基于队列的线程池
    2014-08-20 07:22:06
    标签：队列 线程池 多线程
    版权声明：原创作品，如需转载，请与作者联系。否则将追究法律责任。

    基于队列的线程池

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    66
    67
    68
    69
    70
    71
    72
    73
    74
    75
    76
    77
    78
    79
    80
    81
    82
    83
    84
    85
    86
    87
    88
    89
    90
    91
    92
    93
    94
    95
    96
    97
    98
    99
    100
    101
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
     
    public class TestThreadPool {
        //    public static BlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
        public static ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
     
        public static void main(String[] args) {
            for (int i = 0; i < 3; i++) {
                queue.add(new TestThread("初始化"));
            }
     
            final ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 3, 15, TimeUnit.SECONDS, queue);
            System.out.println("getActiveCount=" + executor.getActiveCount()
                            + ";getKeepAliveTime=" + executor.getKeepAliveTime(TimeUnit.SECONDS)
                            + ";getCompletedTaskCount=" + executor.getCompletedTaskCount()
                            + ";getCorePoolSize=" + executor.getCorePoolSize()
                            + ";getLargestPoolSize=" + executor.getLargestPoolSize()
                            + ";getMaximumPoolSize=" + executor.getMaximumPoolSize()
                            + ";getPoolSize=" + executor.getPoolSize()
                            + ";getTaskCount=" + executor.getTaskCount()
                            + ";getQueue().size()=" + executor.getQueue().size()
            );
            executor.execute(queue.poll());
            System.out.println("getActiveCount=" + executor.getActiveCount()
                            + ";getKeepAliveTime=" + executor.getKeepAliveTime(TimeUnit.SECONDS)
                            + ";getCompletedTaskCount=" + executor.getCompletedTaskCount()
                            + ";getCorePoolSize=" + executor.getCorePoolSize()
                            + ";getLargestPoolSize=" + executor.getLargestPoolSize()
                            + ";getMaximumPoolSize=" + executor.getMaximumPoolSize()
                            + ";getPoolSize=" + executor.getPoolSize()
                            + ";getTaskCount=" + executor.getTaskCount()
                            + ";getQueue().size()=" + executor.getQueue().size()
            );
     
            new Thread(new Runnable() {
                @Override
                public void run() {
                    while (true) {
                        System.out.println("getActiveCount=" + executor.getActiveCount()
                                        + ";getKeepAliveTime=" + executor.getKeepAliveTime(TimeUnit.SECONDS)
                                        + ";getCompletedTaskCount=" + executor.getCompletedTaskCount()
                                        + ";getCorePoolSize=" + executor.getCorePoolSize()
                                        + ";getLargestPoolSize=" + executor.getLargestPoolSize()
                                        + ";getMaximumPoolSize=" + executor.getMaximumPoolSize()
                                        + ";getPoolSize=" + executor.getPoolSize()
                                        + ";getTaskCount=" + executor.getTaskCount()
                                        + ";getQueue().size()=" + executor.getQueue().size()
                        );
                        try {
                            Thread.currentThread().sleep(1000L);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }).start();
     
            new Thread(new Runnable() {
                @Override
                public void run() {
                    int i = 0;
                    while (true) {
                        queue.add(new TestThread("生产者"));
                        try {
                            Thread.currentThread().sleep(500L);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        i++;
                        if (i > 10) break;
                    }
                }
            }).start();
        }
    }
     
    class TestThread implements Runnable {
        public static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        private String name;        //创建者
        private Date addDate;       //添加到队列的日期
     
        TestThread(String name) {
            this.name = name;
            this.addDate = new Date();
        }
     
        @Override
        public void run() {
            System.out.println(Thread.currentThread().getName() +
                    "：创建者=" + name + "，创建时间=" + sdf.format(addDate) + "，执行时间=" + sdf.format(new Date()) + ",当前队列大小=" + TestThreadPool.queue.size());
            try {
                Thread.currentThread().sleep(1000L);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    执行结果：

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=0;getCorePoolSize=2;getLargestPoolSize=0;getMaximumPoolSize=3;getPoolSize=0;getTaskCount=3;getQueue().size()=3
    getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=0;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=3;getQueue().size()=2
    pool-1-thread-1：创建者=初始化，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:19,当前队列大小=2
    getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=0;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=3;getQueue().size()=2
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=1;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=6;getQueue().size()=4
    pool-1-thread-1：创建者=初始化，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:20,当前队列大小=4
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=2;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=8;getQueue().size()=5
    pool-1-thread-1：创建者=初始化，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:21,当前队列大小=5
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=3;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=10;getQueue().size()=6
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:22,当前队列大小=6
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=4;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=12;getQueue().size()=7
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:19，执行时间=2014-08-20 12:08:23,当前队列大小=7
    getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=5;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=8
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:20，执行时间=2014-08-20 12:08:24,当前队列大小=8
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=6;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=7
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:20，执行时间=2014-08-20 12:08:25,当前队列大小=7
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=7;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=6
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:21，执行时间=2014-08-20 12:08:26,当前队列大小=6
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=8;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=5
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:21，执行时间=2014-08-20 12:08:27,当前队列大小=5
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=9;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=4
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:22，执行时间=2014-08-20 12:08:28,当前队列大小=4
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=10;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=3
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:22，执行时间=2014-08-20 12:08:29,当前队列大小=3
    getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=11;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=2
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:23，执行时间=2014-08-20 12:08:30,当前队列大小=2
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=12;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=1
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:23，执行时间=2014-08-20 12:08:31,当前队列大小=1
    getActiveCount=1;getKeepAliveTime=15;getCompletedTaskCount=12;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=1
    pool-1-thread-1：创建者=生产者，创建时间=2014-08-20 12:08:24，执行时间=2014-08-20 12:08:32,当前队列大小=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
    getActiveCount=0;getKeepAliveTime=15;getCompletedTaskCount=14;getCorePoolSize=2;getLargestPoolSize=1;getMaximumPoolSize=3;getPoolSize=1;getTaskCount=14;getQueue().size()=0
     
    Process finished with exit code -1

    这个是理想情况，如果生产者创建速度大于消费者速度，则会随着时间推移耗尽系统资源，这个需要通过RejectedExecutionHandler来实现。

    对这个例子，做了一些改动，可以更加清楚看到执行过程：

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    66
    67
    68
    69
    70
    71
    72
    73
    74
    75
    76
    77
    78
    79
    80
    81
    82
    83
    84
    85
    86
    87
    88
    89
    90
    91
    92
    93
    94
    95
    96
    97
    98
    99
    100
    101
    102
    103
    104
    105
    106
    107
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
     
    public class TestThreadPool {
        //    public static BlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
    //    public static ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
    //    public static ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
        public static LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
     
        public static void main(String[] args) {
            for (int i = 0; i < 2; i++) {
                queue.add(new TestThread("初始化"));
            }
     
            final ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 3, 15, TimeUnit.SECONDS, queue);
    //        System.out.println("getActiveCount=" + executor.getActiveCount()
    //                        + ";getKeepAliveTime=" + executor.getKeepAliveTime(TimeUnit.SECONDS)
    //                        + ";getCompletedTaskCount=" + executor.getCompletedTaskCount()
    //                        + ";getCorePoolSize=" + executor.getCorePoolSize()
    //                        + ";getLargestPoolSize=" + executor.getLargestPoolSize()
    //                        + ";getMaximumPoolSize=" + executor.getMaximumPoolSize()
    //                        + ";getPoolSize=" + executor.getPoolSize()
    //                        + ";getTaskCount=" + executor.getTaskCount()
    //                        + ";getQueue().size()=" + executor.getQueue().size()
    //        );
    //        executor.execute(new Thread());
            executor.prestartCoreThread();
    //        System.out.println("getActiveCount=" + executor.getActiveCount()
    //                        + ";getKeepAliveTime=" + executor.getKeepAliveTime(TimeUnit.SECONDS)
    //                        + ";getCompletedTaskCount=" + executor.getCompletedTaskCount()
    //                        + ";getCorePoolSize=" + executor.getCorePoolSize()
    //                        + ";getLargestPoolSize=" + executor.getLargestPoolSize()
    //                        + ";getMaximumPoolSize=" + executor.getMaximumPoolSize()
    //                        + ";getPoolSize=" + executor.getPoolSize()
    //                        + ";getTaskCount=" + executor.getTaskCount()
    //                        + ";getQueue().size()=" + executor.getQueue().size()
    //        );
     
            new Thread(new Runnable() {
                @Override
                public void run() {
                    while (true) {
                        System.out.println("getActiveCount=" + executor.getActiveCount()
                                        + ";getKeepAliveTime=" + executor.getKeepAliveTime(TimeUnit.SECONDS)
                                        + ";getCompletedTaskCount=" + executor.getCompletedTaskCount()
                                        + ";getCorePoolSize=" + executor.getCorePoolSize()
                                        + ";getLargestPoolSize=" + executor.getLargestPoolSize()
                                        + ";getMaximumPoolSize=" + executor.getMaximumPoolSize()
                                        + ";getPoolSize=" + executor.getPoolSize()
                                        + ";getTaskCount=" + executor.getTaskCount()
                                        + ";getQueue().size()=" + executor.getQueue().size()
                        );
                        try {
                            Thread.currentThread().sleep(200L);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }).start();
     
            new Thread(new Runnable() {
                @Override
                public void run() {
                    int i = 0;
                    while (true) {
                        queue.add(new TestThread("生产者"));
                        try {
                            Thread.currentThread().sleep(100L);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        i++;
                        if (i > 100) break;
                    }
                }
            }).start();
        }
    }
     
    class TestThread implements Runnable {
        public static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        private String name;        //创建者
        private Date addDate;       //添加到队列的日期
     
        TestThread(String name) {
            this.name = name;
            this.addDate = new Date();
        }
     
        @Override
        public void run() {
            System.out.println(Thread.currentThread().getName() +
                    "：创建者=" + name + "，创建时间=" + sdf.format(addDate) + "，执行时间=" + sdf.format(new Date()) + ",当前队列大小=" + TestThreadPool.queue.size());
     
            System.out.println(TestThreadPool.queue.peek());
            try {
                Thread.currentThread().sleep(1000L);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    本文出自 “熔 岩” 博客，转载请与作者联系！
  • 相关阅读:
    洛谷-P1591 阶乘数码
    洛谷-P1328 生活大爆炸版石头剪刀布
    git的使用
    docker下载命令
    springboot学习笔记
    内部类被实例化才会被加载进内存测试
    springboot环境搭建遇到的问题
    Java多线程的锁机制
    spring JdbcTemplate学习
    多线程循环注意
  • 原文地址：https://www.cnblogs.com/donaldlee2008/p/5291852.html
Copyright © 2011-2022 走看看