站长资讯网
最全最丰富的资讯网站

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

java创建线程池的四种方式是:1、newCachedThreadPool创建一个可缓存线程池;2、newFixedThreadPool创建一个定长线程池;3、newScheduledThreadPool创建一个定长线程池。

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

Java通过Executors提供四种线程池,分别为:
newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。

newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。

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

newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。

详细内容可参见博友的博客Java并发编程:线程池的使用

1.newCachedThreadPool 这里的线程池是无限大的,当一个线程完成任务之后,这个线程可以接下来完成将要分配的任务,而不是创建一个新的线程。

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

2.newFixedThreadPool

public static void main(String[] args) {           ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);           for (int i = 0; i < 10; i++) {               final int index = i;               fixedThreadPool.execute(new Runnable() {                   public void run() {                       try {                           System.out.println(index);                           Thread.sleep(10);                       } catch (InterruptedException e) {                           e.printStackTrace();                       }                   }               });           }       }

3.newScheduledThreadPoo

public static void main(String[] args) {           ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);           for (int i = 0; i < 10; i++) {               scheduledThreadPool.schedule(new Runnable() {                   public void run() {                       System.out.println("delay 3 seconds");                   }               }, 3, TimeUnit.SECONDS);           }          }

4.newSingleThreadExecutor 按顺序来执行线程任务 但是不同于单线程,这个线程池只是只能存在一个线程,这个线程死后另外一个线程会补上

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() {   /*                  System.out.println(index);*/                       try {                           System.out.println(index);                           Thread.sleep(2000);                       } catch (InterruptedException e) {                           e.printStackTrace();                       }                   }               });           }       }

推荐教程: 《java教程》

赞(0)
分享到: 更多 (0)

网站地图   沪ICP备18035694号-2    沪公网安备31011702889846号