java使用任务架构执行任务调度示例

代码如下:

package com.yao;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * 新的任务执行架构。
 * 在Java 5.0之前启动一个任务是通过调用Thread类的start()方法来实现的,
 * 任务的提于交和执行是同时进行的,如果你想对任务的执行进行调度,
 * 或是控制同时执行的线程数量就需要额外编写代码来完成。
 * 5.0里提供了一个新的任务执行架构使你可以轻松地调度和控制任务的执行,
 * 并且可以建立一个类似数据库连接池的线程池来执行任务。
 * 这个架构主要有三个接口和其相应的具体类组成。
 * 这三个接口是Executor, ExecutorService和ScheduledExecutorService。
 * (1)Executor接口:是用来执行Runnable任务的,它只定义一个方法:
 * execute(Runnable command):执行Ruannable类型的任务
 * (2)ExecutorService:继承了Executor的方法,并提供了执行Callable任务和中止任务执行的服务,
 * 其定义的方法主要有:
 * submit(task):可用来提交Callable或Runnable任务,并返回代表此任务的Future对象
 * invokeAll(collection of tasks):批处理任务集合,并返回一个代表这些任务的Future对象集合
 * shutdown():在完成已提交的任务后关闭服务,不再接受新任务
 * shutdownNow():停止所有正在执行的任务并关闭服务。
 * isTerminated():测试是否所有任务都执行完毕了。
 * isShutdown():测试是否该ExecutorService已被关闭
 * (3)ScheduledExecutorService:继承ExecutorService,提供了按时间安排执行任务的功能、
 * schedule(task, initDelay): 安排所提交的Callable或Runnable任务在initDelay指定的时间后执行。
 * scheduleAtFixedRate():安排所提交的Runnable任务按指定的间隔重复执行
 * scheduleWithFixedDelay():安排所提交的Runnable任务在每次执行完后,等待delay所指定的时间后重复执行。
 *
 * 通过Executors类来获得各种服务对象。
 * callable(Runnable task): 将Runnable的任务转化成Callable的任务
 * newSingleThreadExecutor: 产生一个ExecutorService对象,这个对象只有一个线程可用来执行任务,若任务多于一个,任务将按先后顺序执行。
 * newCachedThreadPool(): 产生一个ExecutorService对象,这个对象带有一个线程池,线程池的大小会根据需要调整,线程执行完任务后返回线程池,供执行下一次任务使用。
 * newFixedThreadPool(int poolSize):产生一个ExecutorService对象,这个对象带有一个大小为poolSize的线程池,若任务数量大于poolSize,任务会被放在一个queue里顺序执行。
 * newSingleThreadScheduledExecutor:产生一个ScheduledExecutorService对象,这个对象的线程池大小为1,若任务多于一个,任务将按先后顺序执行。
 * newScheduledThreadPool(int poolSize): 产生一个ScheduledExecutorService对象,这个对象的线程池大小为poolSize,若任务数量大于poolSize,任务会在一个queue里等待执行
 */
public class ExecuteArch {

/**
  * 该线程输出一行字符串
  */
 public static class MyThread implements Runnable {
  public void run() {
   System.out.println("Task repeating. " + System.currentTimeMillis());
   try {
    Thread.sleep(1000);
   } catch (InterruptedException e) {
    System.out.println("Task interrupted. "
      + System.currentTimeMillis());
   }
  }
 }

/**
  * 该Callable结束另一个任务
  */
 public static class MyCallable implements Callable {
  private Future future;

public MyCallable(Future future) {
   this.future = future;
  }

public String call() {
   System.out.println("To cancell Task..."
     + +System.currentTimeMillis());
   this.future.cancel(true);
   return "Task cancelled!";
  }
 }

/**
  * @param args
  * @throws ExecutionException
  * @throws InterruptedException
  */
 public static void main(String[] args) throws InterruptedException,
   ExecutionException {
  // 产生一个ExecutorService对象,这个对象带有一个线程池,线程池的大小会根据需要调整,
  // 线程执行完任务后返回线程池,供执行下一次任务使用。
  ExecutorService cachedService = Executors.newCachedThreadPool();
  Future myThreadFuture = cachedService.submit(new MyThread());
  Future myCallableFuture = cachedService.submit(new MyCallable(
    myThreadFuture));
  System.out.println(myCallableFuture.get());
  System.out.println("-----------------");

// 将Runnable任务转换成Callable任务
  Callable myThreadCallable = Executors.callable(new MyThread());
  Future myThreadCallableFuture = cachedService.submit(myThreadCallable);
  // 对于Runnable任务,转换成Callable任务后,也没有返回值
  System.out.println(myThreadCallableFuture.get());
  cachedService.shutdownNow();
  System.out.println("-----------------");

// 产生一个ExecutorService对象,这个对象带有一个大小为poolSize的线程池,
  // 若任务数量大于poolSize,任务会被放在一个queue里顺序执行
  ExecutorService fixedService = Executors.newFixedThreadPool(2);
  fixedService.submit(new MyThread());
  fixedService.submit(new MyThread());
  // 由于线程池大小为2,所以后面的任务必须等待前面的任务执行完后才能被执行。
  myThreadFuture = fixedService.submit(new MyThread());
  myCallableFuture = fixedService.submit(new MyCallable(myThreadFuture));
  System.out.println(myCallableFuture.get());
  fixedService.shutdownNow();
  System.out.println("-----------------");

// 产生一个ScheduledExecutorService对象,这个对象的线程池大小为poolSize,
  // 若任务数量大于poolSize,任务会在一个queue里等待执行
  ScheduledExecutorService fixedScheduledService = Executors
    .newScheduledThreadPool(2);
  // 新建任务1
  MyThread task1 = new MyThread();
  // 使用任务执行服务立即执行任务1,而且此后每隔2秒执行一次任务1。
  myThreadFuture = fixedScheduledService.scheduleAtFixedRate(task1, 0, 2,
    TimeUnit.SECONDS);
  // 新建任务2
  MyCallable task2 = new MyCallable(myThreadFuture);
  // 使用任务执行服务等待5秒后执行任务2,执行它后会将任务1关闭。
  myCallableFuture = fixedScheduledService.schedule(task2, 5,
    TimeUnit.SECONDS);
  System.out.println(myCallableFuture.get());
  fixedScheduledService.shutdownNow();
 }
}

(0)

相关推荐

  • 使用java执行定时任务示例

    这是一个演示如何使用java执行定时任务的实例,本实例开始运行后不会自动结束,请在运行本实例后手动结束程序. 复制代码 代码如下: package com.hongyuan.test; import java.awt.Desktop;import java.io.BufferedInputStream;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import j

  • Java任务调度的常见实现方法与比较详解

    本文实例讲述了Java任务调度的常见实现方法与比较.分享给大家供大家参考,具体如下: 简介: 综观目前的 Web 应用,多数应用都具备任务调度的功能.本文由浅入深介绍了几种任务调度的 Java 实现方法,包括 Timer,Scheduler, Quartz 以及 JCron Tab,并对其优缺点进行比较,目的在于给需要开发任务调度的程序员提供有价值的参考. 任务调度是指基于给定时间点,给定时间间隔或者给定执行次数自动执行任务.这里由浅入深介绍四种任务调度的 Java 实现: Timer Sche

  • java定时任务Timer和TimerTask使用详解

    timer和timertask是jdk自带的定时任务实现,无需导入第三方jar包来完成 1.指定多久之后执行此任务,注意:只会执行一次 public class TimerTest { Timer timer; public TimerTest(int time){ timer = new Timer(); timer.schedule(new timerTaskTest(),time*1000);//timer.schedule(执行的方法,延迟多久执行(ms)) } public stati

  • java多线程并发executorservice(任务调度)类

    复制代码 代码如下: package com.yao; import java.util.concurrent.Executors;import java.util.concurrent.ScheduledExecutorService;import java.util.concurrent.ScheduledFuture;import java.util.concurrent.TimeUnit; /** * 以下是一个带方法的类,它设置了 ScheduledExecutorService ,2

  • Java定时任务的三种实现方法

    译者注:个人觉得用定时任务来跑垃圾回收不是很好的例子,从译者接触到的项目来看,比较常见的是用定时任务来进行非实时计算,清除临时数据.文件等.在本文里,我会给大家介绍3种不同的实现方法:1.普通thread实现2.TimerTask实现3.ScheduledExecutorService实现 一.普通thread 这是最常见的,创建一个thread,然后让它在while循环里一直运行着,通过sleep方法来达到定时任务的效果.这样可以快速简单的实现,代码如下: 复制代码 代码如下: public

  • Java中Spring使用Quartz任务调度定时器

    Quartz 任务调度是什么 Quartz 是 OpenSymphony 开源组织在 Job scheduling 领域又一个开源项目,它可以与 J2EE 与 J2SE 应用程序相结合也可以单独使用.Quartz 是一个完全由 Java 编写的开源作业调度框架.不要让作业调度这个术语吓着你.尽管Quartz框架整合了许多额外功能,但就其简易形式看,你会发现它易用得简直让人受不了! 其实,他还是没有解释明白,我简单说一下:Quartz 作业调度就是可以实现定时任务.它可以实现类似 Windows

  • java定时任务的实现方法

    复制代码 代码如下: package com.ucap.sms; import java.util.Timer; import javax.servlet.ServletContextEvent;import javax.servlet.ServletContextListener; public class SmsListener implements ServletContextListener{    private Timer timer=null; public void contex

  • java自定义任务类定时执行任务示例 callable和future接口使用方法

    Callable 和 Future接口Callable是类似于Runnable的接口,实现Callable接口的类和实现Runnable的类都是可被其它线程执行的任务. Callable和Runnable有几点不同: (1)Callable规定的方法是call(),而Runnable规定的方法是run().(2)Callable的任务执行后可返回值,而Runnable的任务是不能返回值的. (3)call()方法可抛出异常,而run()方法是不能抛出异常的.(4)运行Callable任务可拿到一

  • Java实现的并发任务处理实例

    本文实例讲述了Java实现的并发任务处理方法.分享给大家供大家参考,具体如下: public void init() { super.init(); this.ioThreadPool = new ThreadPoolExecutor(50, 50, Long.MAX_VALUE, TimeUnit.SECONDS, new java.util.concurrent.LinkedTransferQueue<Runnable>(), new ThreadFactory() { AtomicLon

  • java中 spring 定时任务 实现代码

    复制代码 代码如下: import org.apache.log4j.*;public class TaskJob {       public static Logger log = Logger                     .getLogger(TaskJob.class);       public void SayHello() {              // TODO Auto-generated method stub              try {      

随机推荐