package com.person.threadpool;
/*** 任务类 :实现Runnable*/
public class RunnableTask implements Runnable{private int num;public RunnableTask(int num){this.num = num;}@Overridepublic void run() {try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}String threadName = Thread.currentThread().getName();String msg = "当前线程名 ["+threadName+"] 执行任务 [RunnableTask"+num+"] Done";System.out.println(msg);}}

package com.person.threadpool;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ExecutorsnewSingleThreadExecutorTest {public static void main(String[] args) throws Exception{//线程池中只有一个线程，保证所有任务的执行顺序按照任务的提交顺序执行。//如果这个唯一的线程因为异常结束，那么会有一个新的线程来替代它。ExecutorService newSingleThreadExecutor = Executors.newSingleThreadExecutor();// 提交多个任务for (int i = 1; i <= 10; i++) {RunnableTask task = new RunnableTask(i);// 任务
            newSingleThreadExecutor.submit(task);}//主线程休眠，确保任务都执行完成再关闭线程池Thread.currentThread().sleep(1000);newSingleThreadExecutor.shutdown();// 关闭线程池，如果还是线程没有执行完成则会继续执行，只是之后不能添加新的任务
    }}

package com.person.threadpool;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ExecutorsnewFixedThreadPoolTest {public static void main(String[] args) {// 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。//线程池的大小一旦达到最大值就会保持不变，如果某个线程因为执行异常而结束，那么线程池会补充一个新线程。ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(3);// 提交多个任务for (int i = 1; i <= 10; i++) {RunnableTask task = new RunnableTask(i);// 任务
            newFixedThreadPool.submit(task);}newFixedThreadPool.shutdown();// 关闭线程池，如果还是线程没有执行完成则会继续执行，只是之后不能添加新的任务
    }}

package com.person.threadpool;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ExecutorsnewCachedThreadPoolTest {public static void main(String[] args) throws Exception{/*创建一个可缓存的线程池。如果线程池的大小超过了处理任务所需要的线程，*那么就会回收部分空闲（60秒不执行任务）的线程，当任务数增加时，此线程池又可以智能的添加新线程来处理任务。*此线程池不会对线程池大小做限制，线程池大小完全依赖于操作系统（或者说JVM）能够创建的最大线程大小。*/ExecutorService newCachedThreadPool = Executors.newCachedThreadPool();//提交多个任务for(int i=1;i<=10;i++){RunnableTask task = new RunnableTask(i);//任务
            newCachedThreadPool.submit(task);}//主线程暂停，确保执行后面的任务时，前面的任务全部执行完成Thread.currentThread().sleep(4000);System.out.println("==========================================");//重新让线程池执行任务，可以发现 线程池中的线程被重复利用for(int i=11;i<=20;i++){RunnableTask task = new RunnableTask(i);//任务
            newCachedThreadPool.submit(task);}//主线程休眠，确保任务都执行完成再关闭线程池Thread.currentThread().sleep(1000);//关闭线程池
        newCachedThreadPool.shutdown();}}

package com.person.threadpool;import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;public class ExecutorsnewScheduledThreadPoolTest {public static void main(String[] args) {//创建一个定长线程池，支持定时及周期性任务执行ScheduledExecutorService newScheduledThreadPool = Executors.newScheduledThreadPool(3);//延迟执行任务RunnableTask task = new RunnableTask(1);//任务newScheduledThreadPool.schedule(task, 3, TimeUnit.SECONDS); //也可以接收一个Callable实现类任务//周期性任务：延迟3秒执行第一次，每10秒执行一次，不关心上一次是否执行完成RunnableTask periodTask = new RunnableTask(4);//任务newScheduledThreadPool.scheduleAtFixedRate(periodTask, 3, 10, TimeUnit.SECONDS);//延迟3秒执行第一次任务，第一次执行完成再延迟10秒执行第二次，第二次执行完成再延迟10秒执行第三次....RunnableTask fixedDelayTask = new RunnableTask(8);//任务newScheduledThreadPool.scheduleWithFixedDelay(fixedDelayTask, 3, 10, TimeUnit.SECONDS);//newScheduledThreadPool.shutdown(); //当执行周期性任务时，不能关闭线程池，否则任务不被执行。
    }}