• 技术文章 >Java >Java基础

    线程池创建的四种方法是什么

    青灯夜游青灯夜游2023-01-13 00:39:43原创28146

    方法:newCachedThreadPool创建可缓存线程池、newFixedThreadPool创建定长线程池、newScheduledThreadPool创建定长线程池、newSingleThreadExecutor创建单线程化线程池。

    线程池创建的四种方法

    Java通过Executors提供四种线程池,分别为:

    1、使用newCachedThreadPool

    newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。

    这种类型的线程池特点是:

    示例代码如下:

     package test;
     import java.util.concurrent.ExecutorService;
     import java.util.concurrent.Executors;
       public class ThreadPoolExecutorTest {
       public static void main(String[] args) {
       ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
      for (int i = 0; i < 10; i++) {
       final int index = i;
        try {
        Thread.sleep(index * 1000);
        } catch (InterruptedException e) {
         e.printStackTrace();
        }
        cachedThreadPool.execute(new Runnable() {
         public void run() {
          System.out.println(index);
         }
        });
       }
      }
     }

    2、使用newFixedThreadPool

    创建一个指定工作线程数量的线程池。每当提交一个任务就创建一个工作线程,如果工作线程数量达到线程池初始的最大数,则将提交的任务存入到池队列中。

    FixedThreadPool是一个典型且优秀的线程池,它具有线程池提高程序效率和节省创建线程时所耗的开销的优点。但是,在线程池空闲时,即线程池中没有可运行任务时,它不会释放工作线程,还会占用一定的系统资源。

    示例代码如下:

     package test;
     import java.util.concurrent.ExecutorService;
     import java.util.concurrent.Executors;
     public class ThreadPoolExecutorTest {
      public static void main(String[] args) {
       ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
       for (int i = 0; i < 10; i++) {
        final int index = i;
        try {
         Thread.sleep(index * 1000);
        } catch (InterruptedException e) {
         e.printStackTrace();
        }
        cachedThreadPool.execute(new Runnable() {
         public void run() {
          System.out.println(index);
         }
        });
       }
      }
     }

    因为线程池大小为3,每个任务输出index后sleep 2秒,所以每两秒打印3个数字。

    定长线程池的大小最好根据系统资源进行设置如Runtime.getRuntime().availableProcessors()。

    3、使用newSingleThreadExecutor

    创建一个单线程化的Executor,即只创建唯一的工作者线程来执行任务,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO,优先级)执行。如果这个线程异常结束,会有另一个取代它,保证顺序执行。单工作线程最大的特点是可保证顺序地执行各个任务,并且在任意给定的时间不会有多个线程是活动的。

    示例代码如下:

    package test;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    public class ThreadPoolExecutorTest {
     public static void main(String[] args) {
      ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
      for (int i = 0; i < 10; i++) {
       final int index = i;
       singleThreadExecutor.execute(new Runnable() {
        public void run() {
         try {
          System.out.println(index);
          Thread.sleep(2000);
         } catch (InterruptedException e) {
          e.printStackTrace();
         }
        }
       });
      }
     }
    }

    4、使用newScheduledThreadPool

    创建一个定长的线程池,而且支持定时的以及周期性的任务执行,支持定时及周期性任务执行。

    延迟3秒执行,延迟执行示例代码如下:

    package test;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    public class ThreadPoolExecutorTest {
     public static void main(String[] args) {
      ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
      scheduledThreadPool.schedule(new Runnable() {
       public void run() {
        System.out.println("delay 3 seconds");
       }
      }, 3, TimeUnit.SECONDS);
     }
    }

    表示延迟1秒后每3秒执行一次,定期执行示例代码如下:

    package test;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    public class ThreadPoolExecutorTest {
     public static void main(String[] args) {
      ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
      scheduledThreadPool.scheduleAtFixedRate(new Runnable() {
       public void run() {
        System.out.println("delay 1 seconds, and excute every 3 seconds");
       }
      }, 1, 3, TimeUnit.SECONDS);
     }
    }

    更多编程相关知识,请访问:编程学习网站!!

    以上就是线程池创建的四种方法是什么的详细内容,更多请关注php中文网其它相关文章!

    声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn核实处理。
    专题推荐:线程池 java
    上一篇:详解JVM创建对象及访问定位过程 下一篇:自己动手写 PHP MVC 框架(40节精讲/巨细/新人进阶必看)

    相关文章推荐

    • java面试之数据库性能优化• java 是前端还是后端• java小测试之求1000以内的完数• java面试之内存模型
    1/1

    PHP中文网