线程池的三大方法

线程池的三大方法

Executors.newSingleThreadExecutor(); 单线程

Executors.newFixedThreadPool(5); 固定线程个数

Executors.newCachedThreadPool(); 缓存池，可扩展

Executors.newSingleThreadExecutor(); 单线程

package pool;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/** * Executors 工具类、3大方法 */

public class Demo01 {
    
    public static void main(String[] args) {
    
        ExecutorService threadPool = Executors.newSingleThreadExecutor();//单个线程

        try {
    
        for (int i = 0; i < 10; i++) {
    
            //使用了线程池之后，使用线程池来创建线程
            threadPool.execute(()->{
    
                System.out.println(Thread.currentThread().getName()+"OK！");
            });
        }
        } catch (Exception e) {
    
            e.printStackTrace();
        } finally {
    
            //线程池用完，程序结束，关闭线程池
            threadPool.shutdown();
        }
    }
}

Executors.newFixedThreadPool(5); 固定线程个数

package pool;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/** * Executors 工具类、3大方法 */

public class Demo01 {
    
    public static void main(String[] args) {
    
        ExecutorService threadPool = Executors.newFixedThreadPool(5); //创建一个固定的线程池的大小
    
        try {
    
        for (int i = 0; i < 10; i++) {
    
            //使用了线程池之后，使用线程池来创建线程
            threadPool.execute(()->{
    
                System.out.println(Thread.currentThread().getName()+" OK！");
            });
        }
        } catch (Exception e) {
    
            e.printStackTrace();
        } finally {
    
            //线程池用完，程序结束，关闭线程池
            threadPool.shutdown();
        }
    }
}

Executors.newCachedThreadPool(); 缓存池，可扩展

1package pool;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/** * Executors 工具类、3大方法 */

public class Demo01 {
    
    public static void main(String[] args) {
    

        ExecutorService threadPool = Executors.newCachedThreadPool();//可伸缩的，遇强则强，遇弱则弱

        try {
    
        for (int i = 0; i < 100; i++) {
    
            //使用了线程池之后，使用线程池来创建线程
            threadPool.execute(()->{
    
                System.out.println(Thread.currentThread().getName()+" OK！");
            });
        }
        } catch (Exception e) {
    
            e.printStackTrace();
        } finally {
    
            //线程池用完，程序结束，关闭线程池
            threadPool.shutdown();
        }
    }
}