ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4);// 不推荐
// 或
ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(4);// 推荐
public interface ScheduledExecutorService extends ExecutorService { public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit); public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit);
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit);
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit); }
package com.java.scheduled.task.pool; import java.text.SimpleDateFormat; import java.util.Date; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ScheduledTaskDemo01 { public static void main(String[] args) { ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(4); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date date = new Date(); System.out.println("安排执行任务的时间："+sdf.format(date)); long c1 = date.getTime(); Runnable runnable = () -> { Date nowDate = new Date(); System.out.println("****计划任务（1）：【延迟2秒执行】"); System.out.println("实际执行任务的时间："+sdf.format(nowDate)); System.out.println("延迟时间："+(nowDate.getTime() - c1)+"ms"); }; executorService.schedule(runnable, 2, TimeUnit.SECONDS); } }
执行结果如下：
安排执行任务的时间：2019-05-28 12:10:46 ****计划任务（1）：【延迟2秒执行】 实际执行任务的时间：2019-05-28 12:10:48 延迟时间：2087ms
package com.java.scheduled.task.pool; import java.text.SimpleDateFormat; import java.util.Date; import java.util.concurrent.*; public class ScheduledTaskDemo02 { public static void main(String[] args) { ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date date = new Date(); System.out.println("安排执行任务的时间："+sdf.format(date)); long c2 = date.getTime(); Callable<String> callable = () -> { Date nowDate = new Date(); System.out.println("****计划任务（2）：【延迟2秒执行，执行结束返回结果】"); System.out.println("实际执行任务的时间："+sdf.format(nowDate)); System.out.println("延迟时间："+(nowDate.getTime() - c2)+"ms"); Thread.sleep(1000); System.out.println("任务执行完毕，当前时间："+sdf.format(new Date())); return "success"; }; ScheduledFuture<String> scheduledFuture = executorService.schedule(callable, 2, TimeUnit.SECONDS); try { System.out.println("任务的执行结果："+scheduledFuture.get()); } catch (ExecutionException e1) { e1.printStackTrace(); } catch (InterruptedException e2) { e2.printStackTrace(); } } }
执行结果如下：
安排执行任务的时间：2019-05-28 12:14:05 ****计划任务（2）：【延迟2秒执行，执行结束返回结果】 实际执行任务的时间：2019-05-28 12:14:07 延迟时间：2072ms 任务执行完毕，当前时间：2019-05-28 12:14:08 任务的执行结果：success
package com.java.scheduled.task.pool; import java.text.SimpleDateFormat; import java.util.Date; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; public class ScheduledTaskDemo03 { public static void main(String[] args) { ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date date = new Date(); System.out.println("安排执行任务的时间："+sdf.format(date)); long c3 = date.getTime(); Runnable runnable = new Runnable() { long exeTime = c3; @Override public void run() { Date nowDate = new Date(); System.out.println("--------------------------------------------------------------------------------"); System.out.println("计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】"); System.out.println("****实际执行任务的时间："+sdf.format(nowDate)); System.out.println("****距离上次执行任务的时间间隔："+(nowDate.getTime() - exeTime)+"ms"); try { Thread.sleep(4000); } catch (InterruptedException e) {} exeTime = nowDate.getTime(); } }; executorService.scheduleAtFixedRate(runnable, 1, 2, TimeUnit.SECONDS); } }
执行结果如下：
安排执行任务的时间：2019-05-28 12:15:12 -------------------------------------------------------------------------------- 计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】 ****实际执行任务的时间：2019-05-28 12:15:13 ****距离上次执行任务的时间间隔：1003ms -------------------------------------------------------------------------------- 计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】 ****实际执行任务的时间：2019-05-28 12:15:17 ****距离上次执行任务的时间间隔：4002ms -------------------------------------------------------------------------------- 计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】 ****实际执行任务的时间：2019-05-28 12:15:21 ****距离上次执行任务的时间间隔：4001ms -------------------------------------------------------------------------------- 计划任务（3）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】 ****实际执行任务的时间：2019-05-28 12:15:25 ****距离上次执行任务的时间间隔：4002ms
package com.java.scheduled.task.pool; import java.text.SimpleDateFormat; import java.util.Date; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; public class ScheduledTaskDemo04 { public static void main(String[] args) { ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date date = new Date(); System.out.println("安排执行任务的时间："+sdf.format(date)); long c3 = date.getTime(); Runnable runnable = new Runnable() { long exeTime = c3; @Override public void run() { Date nowDate = new Date(); System.out.println("--------------------------------------------------------------------------------"); System.out.println("计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】"); System.out.println("****实际执行任务的时间："+sdf.format(nowDate)); System.out.println("****距离上次执行任务的时间间隔："+(nowDate.getTime() - exeTime)+"ms"); try { Thread.sleep(2500); } catch (InterruptedException e) {} exeTime = nowDate.getTime(); } }; executorService.scheduleWithFixedDelay(runnable, 1, 2, TimeUnit.SECONDS); } }
执行结果如下：
安排执行任务的时间：2019-05-28 12:16:56 -------------------------------------------------------------------------------- 计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】 ****实际执行任务的时间：2019-05-28 12:16:57 ****距离上次执行任务的时间间隔：1018ms -------------------------------------------------------------------------------- 计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】 ****实际执行任务的时间：2019-05-28 12:17:01 ****距离上次执行任务的时间间隔：4504ms -------------------------------------------------------------------------------- 计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】 ****实际执行任务的时间：2019-05-28 12:17:06 ****距离上次执行任务的时间间隔：4502ms -------------------------------------------------------------------------------- 计划任务（4）：【延迟1秒执行第一次任务，之后每过2秒执行一次任务】 ****实际执行任务的时间：2019-05-28 12:17:10 ****距离上次执行任务的时间间隔：4502ms
原文：https://www.cnblogs.com/517cn/p/10936460.html