线程池

标签：面向接口   tor   void   实现类   get   nbsp   对象   提交   code   

线程池：其实就是一个容纳多个线程的容器，其中的线程可以反复使用，省去了频谱创建线程对象的操作，无需反复创建线程而消耗过多的资源；

package demo06;

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class demo01thread implements Runnable{


    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName()+"创建了一个新的线程执行");
    }
}

package demo06;

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

/*
* java.util.concurrent.Executors：线程池的工类，用来生产线程池；
* Executors类中的静态方法
* static ExecutorService newFixedThreadPool(int nThreads)
          创建一个可重用固定线程数的线程池，以共享的无界队列方式来运行这些线程。
          返回值：
          *     ExecutorService接口，返回的是ExecutorService接口的实现类对象，我们可以使用ExecutorService
          * 接口接收（面向接口编程）
          *
        java.util.concurrent：线程池接口
        * 用来从线程池中获取线程，调用start方法，执行线程任务
        *  Future<?> submit(Runnable task)
          提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。
         关闭或者销毁线程池
         * void shutdown（）
         *
      线程池的使用步骤
      * 1使用线程池的工厂类Executors里面提供的静态方法newFixedThreadPool生产一个指定线程数量的线程池
      * 2创建一个类，实现Runnable接口，重写run方法，设置线程任务，
      * 3调用ExecutorService中的方法submit，传递线程任务（实现类），开启线程，执行run方法
      * 4调用ExecutorService中的方法shutdown销毁线程池
* */
public class demo06{
    public static void main(String[] args) {
//    1使用线程池的工厂类Executors里面提供的静态方法newFixedThreadPool生产一个指定线程数量的线程池
        ExecutorService es= Executors.newFixedThreadPool(2);
//        2创建一个类，实现Runnable接口，重写run方法，设置线程任务，
//        3调用ExecutorService中的方法submit，传递线程任务（实现类），开启线程，执行run方法
        es.submit(new demo01thread());
        //线程池一直开启，使用完了线程，会自动吧线程归还给线程池，线程可以继续使用；
        es.submit(new demo01thread());
        es.submit(new demo01thread());
        es.shutdown();
    }
}

线程池

标签：面向接口   tor   void   实现类   get   nbsp   对象   提交   code   

原文地址：https://www.cnblogs.com/Damocless/p/11875786.html