java线程池的四种实现方式

喜欢ヅ旅行 2022-05-17 00:38 265阅读 0赞

# 一、newCachedThreadPool #

package com.mmall.concurrency.example.threadPool;
    
    import lombok.extern.slf4j.Slf4j;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    @Slf4j
    public class ThreadPoolExample1 { 
    
        public static void main(String[] args) {
    
            ExecutorService executorService = Executors.newCachedThreadPool();
    
            for (int i = 0; i < 10; i++) {
                final int index = i;
                executorService.execute(new Runnable() {
                    @Override
                    public void run() {
                        log.info("task:{}", index);
                    }
                });
            }
            executorService.shutdown();
        }
    }

# 二、newFixedThreadPool #

package com.mmall.concurrency.example.threadPool;
    
    import lombok.extern.slf4j.Slf4j;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    @Slf4j
    public class ThreadPoolExample2 { 
    
        public static void main(String[] args) {
    
            ExecutorService executorService = Executors.newFixedThreadPool(3);
    
            for (int i = 0; i < 10; i++) {
                final int index = i;
                executorService.execute(new Runnable() {
                    @Override
                    public void run() {
                        log.info("task:{}", index);
                    }
                });
            }
            executorService.shutdown();
        }
    }

# 三、newScheduledThreadPool #

package com.mmall.concurrency.example.threadPool;
    
    import lombok.extern.slf4j.Slf4j;
    
    import java.util.Date;
    import java.util.Timer;
    import java.util.TimerTask;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    
    @Slf4j
    public class ThreadPoolExample4 { 
    
        public static void main(String[] args) {
    
            ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
    
    // executorService.schedule(new Runnable() { 
    // @Override
    // public void run() { 
    // log.warn("schedule run");
    // }
    // }, 3, TimeUnit.SECONDS);
    
            executorService.scheduleAtFixedRate(new Runnable() {
                @Override
                public void run() {
                    log.warn("schedule run");
                }
            }, 1, 3, TimeUnit.SECONDS);
    // executorService.shutdown();
    
            Timer timer = new Timer();
            timer.schedule(new TimerTask() {
                @Override
                public void run() {
                    log.warn("timer run");
                }
            }, new Date(), 5 * 1000);
        }
    }

# 四、newSingleThreadExecutor #

package com.mmall.concurrency.example.threadPool;
    
    import lombok.extern.slf4j.Slf4j;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    @Slf4j
    public class ThreadPoolExample3 { 
    
        public static void main(String[] args) {
    
            ExecutorService executorService = Executors.newSingleThreadExecutor();
    
            for (int i = 0; i < 10; i++) {
                final int index = i;
                executorService.execute(new Runnable() {
                    @Override
                    public void run() {
                        log.info("task:{}", index);
                    }
                });
            }
            executorService.shutdown();
        }
    }

[参考1][1]  
[参考2][2]

[1]: https://blog.csdn.net/yunan0808/article/details/78700272
[2]: https://www.cnblogs.com/dolphin0520/p/3932921.html