您的位置：首页 > 其它

多种实现方案------------ 多线程

2017-07-09 08:58 288 查看 
package Thread05;

import java.util.Date;
import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;

public class Calls implements Callable<Object> {
private String taskNum;

Calls(String taskNum) {
this.taskNum = taskNum;
}

@Override
public Object call() throws Exception {
System.out.println(">>>" + taskNum + "任务启动");

Date dateTmp1 = new Date();
Thread.sleep(1000);
Date dateTmp2 = new Date();
long time = dateTmp2.getTime() - dateTmp1.getTime();
System.out.println(">>>" + taskNum + "任务终止");
return taskNum + "任务返回结果，当前任务时间" + time + "毫秒";
}

}


package Thread05;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class Test {

/**
* @param args
* @throws Exception
*/
public static void main(String[] args) throws Exception {
System.out.println("程序开始运行-----");
Date date1 = new Date();
int taskSize = 5;
// 创建一个线程池
ExecutorService pool = Executors.newFixedThreadPool(taskSize);
List<Future> list = new ArrayList<Future>();
for (int i = 0; i < taskSize; i++) {
Callable c = new Calls(i + " ");
// 执行任务并获取Future对象
Future f = pool.submit(c);
list.add(f);
}
// 关闭线程池
pool.shutdown();
// 获取所有并发任务的运行结果
for (Future f : list) {
// 从Future对象上获取任务的返回值，并输出到控制台
System.out.println(">>>" + f.get().toString());

}

Date date2 = new Date();
System.out.println("-----程序运行结束---运行时间="
+ (date2.getTime() - date1.getTime()));
}

}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 点击这里给我发消息
标签： 
相关文章推荐
新的分享
章节导航