package com.th.threadPool;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/**
* Created by Administrator on 2018/6/6.
* newScheduledThreadPool 创建一个固定长度线程池，支持定时及周期性任务执行。
*/
public class NewScheduledThreadPool {
public static void main(String[] args) {
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5);
//testSchedule(scheduledExecutorService);
//testScheduleAtFixedRate(scheduledExecutorService);
testScheduleWithFixedDelay(scheduledExecutorService);
// 终止线程池
//scheduledExecutorService.shutdown();
}
/**
*
* 跟 testScheduleAtFixedRate 非常类似，就是延迟的时间有点区别
* 创建并执行一个在给定初始延迟后首次启用的定期操作，后续操作具有给定的周期；
* 也就是将在 initialDelay 后开始执行，然后在 initialDelay+period 后执行，
* 接着在 initialDelay + 2 * period 后执行，依此类推。
*
* 如果任务里面执行的时间大于 period 的时间，下一次的任务会推迟执行。
* 推迟的时间 ： 等到上次的任务执行完之后再延迟period 的时间后执行。
* @param scheduledExecutorService
*/
private static void testScheduleWithFixedDelay(ScheduledExecutorService scheduledExecutorService) {
scheduledExecutorService.scheduleWithFixedDelay(new Runnable() {
@Override
public void run() {
try {
System.out.println("延迟2秒，再3秒执行一次");
//如果任务里面执行的时间大于 period 的时间，下一次的任务会推迟执行。
//本次任务执行完后下次的任务还需要延迟period时间后再执行
Thread.sleep(6*1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
},2,3,TimeUnit.SECONDS);
}
/**
* 创建并执行一个在给定初始延迟后首次启用的定期操作，后续操作具有给定的周期；
* 也就是将在 initialDelay 后开始执行，然后在 initialDelay+period 后执行，
* 接着在 initialDelay + 2 * period 后执行，依此类推。
*
* 如果任务里面执行的时间大于 period 的时间，下一次的任务会推迟执行。
* 推迟的时间 ： 等到上次的任务执行完就立马执行。
* @param scheduledExecutorService
*/
private static void testScheduleAtFixedRate(ScheduledExecutorService scheduledExecutorService) {
scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
try {
System.out.println("延迟2秒，再3秒执行一次");
//如果任务里面执行的时间大于 period 的时间，下一次的任务会推迟执行。
//如果任务里面执行的时间大于 period 的时间，本次任务执行完后，下次任务立马执行。
Thread.sleep(6*1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
},2,3,TimeUnit.SECONDS);
}
/**
* 创建并执行在给定延迟后启用的一次性操作
* @param scheduledExecutorService
*/
private static void testSchedule(ScheduledExecutorService scheduledExecutorService) {
scheduledExecutorService.schedule(new Runnable() {
@Override
public void run() {
System.out.println("delay 3 seconds");
}
}, 3, TimeUnit.SECONDS);
}
}
java 四种线程池实例
需积分: 50 177 浏览量
2018-06-06
16:01:55
上传
评论
收藏 25KB ZIP 举报
ThreadPool.zip （26个子文件） 
ThreadPool src com th threadPool 
NewFixedThreadPool.java 2KB NewScheduledThreadPool.java 4KB NewCachedThreadPool.java 2KB NewSingleThreadExecutor.java 2KB Main.java 124B .idea misc.xml 489B vcs.xml 173B
description.html 97B modules.xml 267B encodings.xml 171B compiler.xml 734B workspace.xml 43KB inspectionProfiles ThreadPool.iml 437B out production ThreadPool com th threadPool NewCachedThreadPool$1.class 717B NewSingleThreadExecutor$1.class 1KB NewSingleThreadExecutor.class 980B NewScheduledThreadPool$1.class 1KB NewScheduledThreadPool.class 2KB NewScheduledThreadPool$2.class 1KB NewScheduledThreadPool$3.class 762B NewCachedThreadPool.class 1KB NewFixedThreadPool.class 2KB NewFixedThreadPool$1.class 626B NewFixedThreadPool$2.class 626B NewCachedThreadPool$2.class 717B Main.class 516B资源评论
