Java线程池主要方法详解

待我称王封你为后i 2022-12-10 10:06 3阅读 0赞

## 线程池特点  ##

1.  减少频繁创建 / 销毁线程，减少系统开销
2.  提高系统响应速度，当有新任务时，通过复用存在的空闲线程，无需等待创建新线程便能立即执行
3.  方便对线程并发数的控制

import java.util.concurrent.*;
    import java.util.concurrent.atomic.AtomicInteger;
    
    public static void main(String[] args) throws Exception {
            //原子类
            AtomicInteger count = new AtomicInteger(0);
    
            //固定线程池(这是设置为100条)，可控制最大线程并发数，超出的线程会在队列中等待
            ExecutorService fixedServer = Executors.newFixedThreadPool(100);
            for (int n = 0; n < 100; n++) {
                Future<Boolean> f = fixedServer.submit(new Caller1("001" + n));
                if (f.get()) {
                    //原子类自增
                    count.incrementAndGet();
                }
            }
    
            //单线程池，只有一个线程执行任务，所有任务按指定顺序执行，先进先出
            ExecutorService singleServer = Executors.newSingleThreadExecutor();
            Future<Boolean> si = singleServer.submit(new Caller1("001"));
            if (si.get()) {
                count.incrementAndGet();
            }
    
            //可缓存线程池(无限制线程数，有空闲线程重复使用，无空闲线程创建线程)
            //好处：减少频繁创建/销毁线程，减少系统开销
            ExecutorService cachedServer = Executors.newCachedThreadPool();
            Future<Boolean> c = cachedServer.submit(new Caller1("001"));
            if (c.get()) {
                count.incrementAndGet();
            }
    
            //定时、周期性任务的线程池，支持定时及周期性任务执行(当前设置一条线程)
            ScheduledExecutorService scheduledServer = Executors.newScheduledThreadPool(1);
            //一分钟后执行，只执行一次，没有周期性
            ScheduledFuture<Boolean> s = scheduledServer.schedule(new Caller1("0001"), 1, TimeUnit.SECONDS);
            //initialDelay：等待多久开始执行
            //固定频率，period指的是一次成功执行和下一次成功执行之间的时间
            //上一个任务开始的时间计时，period时间过去后，检测上一个任务是否执行完毕
            //如果上一个任务执行完毕，则当前任务立即执行，如果上一个任务没有执行完毕，则需要等上一个任务执行完毕后立即执行
            //例如：第一次开始执行是3s后，假如执行耗时1s，那么下次开始执行是6s后，再下次开始执行是9s后
            ScheduledFuture<?> scheduledFuture = scheduledServer.scheduleAtFixedRate((Runnable) new Caller1("0001"), 0, 3, TimeUnit.SECONDS);
            //固定延时，delay参数指的是一次执行停止到下一次执行开始之间的延迟
            //上一个任务结束时开始计时，按delay=3分钟固定等待时间后重复立即执行(任务执行时间+delay耗时时间)，
            //例如：第一次开始执行是3s，耗时1s，执行完成时间是4s,那下次开始执行就是7s后，再下次开始执行就是11s后
            ScheduledFuture<?> scheduledFuture1 = scheduledServer.scheduleWithFixedDelay((Runnable) new Caller1("0001"), 0, 3, TimeUnit.SECONDS);
            if (s.get()) {
                count.incrementAndGet();
            }
        }