线程Thread和线程池

package com.xxx.xxx.xxx.thread;import java.util.concurrent.*;public class ThreadTest { public static ExecutorService service = Executors.newFixedThreadPool(10); public static void main(String[] args) throws ExecutionException, InterruptedException { //我们以后在业务代码里面，以上三种启动线程的方式都不用。【将所有的多线程异步任务都交给线程池执行】 // new Thread(() -> System.out.println("hello")).start(); //当前系统中现线程池只有一两个，每个异步任务直接提交给线程池，让它自己去执行 System.out.println("main.......start......"); ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 200, 10, TimeUnit.SECONDS, new linkedBlockingDeque<>(100000), Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());// Executors.newCachedThreadPool();core是0，所有都可回收// Executors.newFixedThreadPool();固定大小，core=max；都不可回收// Executors.newScheduledThreadPool()定时任务的线程池// Executors.newSingleThreadExecutor()单线程的线程池，后台从队列里面获取任务，挨个执行 System.out.println("main.......end......"); } public static class Thread01 extends Thread { @Override public void run() { System.out.println("当前线程：" + Thread.currentThread().getId()); int i = 10 / 2; System.out.println("运行结果：" + i); } } public static class Runnable01 implements Runnable { @Override public void run() { System.out.println("当前线程：" + Thread.currentThread().getId()); int i = 10 / 2; System.out.println("运行结果：" + i); } } public static class Callable01 implements Callable { @Override public Integer call() throws Exception { System.out.println("当前线程：" + Thread.currentThread().getId()); int i = 10 / 2; System.out.println("运行结果：" + i); return i; } }}