JDK5.0新特性系列---11.2线程 任务执行架构-阿里云开发者社区

开发者社区> 老朱教授> 正文

JDK5.0新特性系列---11.2线程 任务执行架构

简介:
+关注继续查看

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;

/**

J2SE之前启动一个任务是通过调用Thread类的start方法来实现的,任务的提交和执行是同时进行的,如果想对任务的执行进行调度,或是控制同时执行的线程数量就需要额外的编写代码来完成.

J2SE5.0提供了一个新的任务执行架构,可以轻松地高度和控制任务的执行,并且可以建立一个线程池来执行任务.

实例介绍如何使用新的任务执行架构,运行RunnableCallable任务,包括定时执行任务,按规律执行任务和停止任务.

关键技术剖析:

使用新的任务执行框架的关键技术如下:

1.Executor服务对象是用来执行Runnable任务的,常用的方法如下:

execute方法用于执行Runnable类型的任务.

2.ExecutorService服务对象能执行和终止Callable任务,它继承了Executor,所以也能执行Runnable任务.常用的方法如下

a) submit方法用来提交CallableRunnable任务,并返回代表此任务的Future对象.

b) invokeAll方法批处理任务集合,并返回一个代表这些任务的Future对象集合

c) shutdown方法在完成自己已提交的任务后关闭服务,不再接受新任务.

d) shutdownNow方法停止所有正在执行的任务并关闭服务.

e) isTerminated测试是否所有任务都执行完毕了

g) isShutdown测试是否该ExecutorService已被关闭

3.ScheduledExecutorService服务对象继承ExecutorService,提供了按时间安排执行任务的功能.常用的方法如下:

a)schedule(task,initDelay)方法安排所提交的CallableRunnable任务在initDelay指定的时间后执行.

b)scheduleAtFixedRate方法安排所提交的Runnable任务按指定的间隔重复执行.

c)scheduleWithFixedDelay方法安排所提交的Runnable任务在每次执行完后,等待delay所指定的时间后重复执行.

4.Executors类用来创建各种服务对象,常用的方法如下:

a)callable(Runnable task)方法将Runnable的任务转化成Callable的任务.

b)newSingleThreadExecutor方法产生一个ExecutorService对象,这个对象带有一个线程,线程池的大小会根据需要调整,线程执行完任务后返回线程池,供执行下一次任务使用.

c)newCachedThreadPool方法会产生一个ExecutorService对象,这个对象带有一个线程池,线程池的大小会根据需要调整,线程执行完任务后返回线程池,供执行下一次任务使用.

d)newFixedThreadPool(int poolSize)方法产生一个ExecutorService对象,这个对象带有一个大小为poolSize的线程池,若任务数量大于poolSize,任务会被放在一个队列里顺序执行.

e)newSingleThreadScheduledExecutor方法产生一个ScheduledExecutorService对象,个对象的线程池大小为1,若任务多于一个,任务将按先后顺序执行.

f)newScheduledThreadPool(int poolSize)方法产生一个ScheduledExecutorService,这个对象的线程池大小为poolSize,若任务数量大于poolSize,任务会在一个队列里等待执行.

*/

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!";

}

}

public static void main(String... args)throwsInterruptedException,ExecutionException{

//产生一个ExcutorService对象,这个对象带有一个线程池,线程池的大小会根据需要调整

//线程执行完任务后返回线程池,供执行下一次任务使用

ExecutorService cachedService = Executors.newCachedThreadPool();

Future myThreadFuture = cachedService.submit(new MyThread());

Future myCallableFuture = cachedService.submit(newMyCallable(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());

myThreadFuture = fixedService.submit(new MyCallable(myThreadFuture));

System.out.println(myCallableFuture.get());

fixedService.shutdown();

System.out.println("--------------------");

//产生一个ScheduleExecutorService对象,这个对象的线程池大小为poolSize

//若任务数量大于poolSize,任务会在一个queue里等待执行

ScheduledExecutorService fixedScheduledService = Executors.newScheduledThreadPool(2);

MyThread task1 = new MyThread();

//使用任务执行服务立即执行任务1,而且此后每隔2秒执行一次任务1

myThreadFuture = fixedScheduledService.scheduleAtFixedRate(task1, 0, 2, TimeUnit.SECONDS);

MyCallable task2 = new MyCallable(myThreadFuture);

//使用任务执行服务等待5秒后执行任务2,执行它后将任务1关闭.

myCallableFuture = fixedScheduledService.schedule(task2,5,TimeUnit.SECONDS);

System.out.println(myCallableFuture.get());

fixedScheduledService.shutdownNow();

}

}




本文转自远哥博客园博客,原文链接:http://www.cnblogs.com/taven/archive/2011/12/17/2291469.html,如需转载请自行联系原作者

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
C#.NET使用Task,await,async,异步执行控件耗时事件(event),不阻塞UI线程和不跨线程执行UI更新,以及其他方式比较
原文:C#.NET使用Task,await,async,异步执行控件耗时事件(event),不阻塞UI线程和不跨线程执行UI更新,以及其他方式比较 使用Task,await,async,异步执行事件(event),不阻塞UI线程和不跨线程执行UI更新   使用Task,await,async 的异步模式 去执行事件(event) 解决不阻塞UI线程和不夸跨线程执行UI更新报错的最佳实践,附加几种其他方式比较 由于是Winform代码和其他原因,本文章只做代码截图演示,不做界面UI展示,当然所有代码都会在截图展示。
3334 0
[20120104]稳定一条sql语句的执行计划.txt
[20120104]稳定一条sql语句的执行计划.txthttp://www.itpub.net/thread-1495845-1-1.htmlhttp://space.
450 0
Redis 6.0 正式版终于发布了!除了多线程还有什么新功能?
云栖号资讯:【点击查看更多行业资讯】在这里您可以找到不同行业的第一手的上云资讯,还在等什么,快来! Redis 6.0.1 于 2020 年 5 月 2 日正式发布了,如 Redis 作者 antirez 所说,这是迄今为止最“企业”化的版本,也是有史以来改动最大的一个 Redis 版本,同时也是参与开发人数最多的一个版本。
751 0
【Android NDK 开发】JNI 线程 ( JNI 线程创建 | 线程执行函数 | 非 JNI 方法获取 JNIEnv 与 Java 对象 | 线程获取 JNIEnv | 全局变量设置 )
【Android NDK 开发】JNI 线程 ( JNI 线程创建 | 线程执行函数 | 非 JNI 方法获取 JNIEnv 与 Java 对象 | 线程获取 JNIEnv | 全局变量设置 )
19 0
机密计算: 一种基于硬件的、服务于应用和数据的可信执行计算形态
注:本文是对[机密计算联盟](https://confidentialcomputing.io/)发布的白皮书[Confidential Computing: Hardware-Based Trusted Execution for Applications and Data v1.2](https://confidentialcomputing.io/wp-content/uploads/sit
552 0
+关注
3546
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载