文档章节

java有返回值的多线程示例

登琼
 登琼
发布于 2017/01/17 18:26
字数 422
阅读 292
收藏 1
import java.util.ArrayList;
import java.util.List;
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;

/**
 * Java线程:有返回值的线程
 * @author <a href="http://git.oschina.net/denger"> 羊登琼 </a>
 */
public class CallableTest {
	public static void main(String[] args) throws ExecutionException, InterruptedException {

		int threadNum = 4;

		// 创建一个线程池
		ExecutorService pool = Executors.newCachedThreadPool();

		// // 创建两个有返回值的任务
		// Callable c1 = new MyCallable("A");
		// Callable c2 = new MyCallable("B");
		//
		// // 执行任务并获取Future对象
		// Future f1 = pool.submit(c1);
		// Future f2 = pool.submit(c2);
		//
		// // 从Future对象上获取任务的返回值,并输出到控制台
		// System.out.println(">>>" + f1.get().toString());
		// System.out.println(">>>" + f2.get().toString());

		/**
		 * 表示各个线程返回结果的总和
		 */
		int count = 0;

		int waitTime = 10;
		/**
		 * 存放线程结果的对象,为了让main线程循环询问子线程结果,进行等待
		 */
		List<Future<Integer>> futures = new ArrayList<>();

		// 创建4个线程
		for (int i = 0; i < threadNum; i++) {
			MyCallable c1 = new MyCallable("" + i, 400);
			Future<Integer> future = pool.submit(c1);
			futures.add(future);
		}

		// 进行判断线程是否结束,目的是让main主线程等待子线程
		boolean isDone = false;
		for (Future<Integer> future : futures) {
			do {
				isDone = future.isDone();
				if (isDone) {
					count = count + future.get();
				} else {
					// 等待两秒,因为它一直询问,执行者很烦,我觉得效率会耽误执行者
					System.out.printf("main主线程进行等待...%s毫秒(ms)\n", waitTime);
					Thread.sleep(waitTime);
				}
			} while (!isDone);
			isDone = false;
		}
		// 线程阻塞结束

		System.out.println(String.format("总共执行%s", count));
		// 关闭线程池
		pool.shutdown();

	}

}

/**
 * 线程类
 * @author <a href="http://git.oschina.net/denger"> 羊登琼 </a>
 */
class MyCallable implements Callable<Integer> {
	/**
	 * 存放变量
	 */
	private String oid;

	/**
	 * 循环次数代表业务处理
	 */
	private Integer length = 400;

	MyCallable(String oid, Integer length) {
		this.oid = oid;
		this.length = length;
	}

	@Override
	public Integer call() throws Exception {
		for (int i = 0; i < length; i++) {
			System.out.println(String.format("%s_____线程的任务_____%s", oid, i));
		}
		return length;
	}
}

以后有需要的时候回来参考一下,脑袋再好也没有笔记好

© 著作权归作者所有

登琼
粉丝 3
博文 47
码字总数 8538
作品 0
广州
程序员
私信 提问
java.lang.ThreadLocal类研究

java.lang.ThreadLocal类研究 1、概述 ThreadLocal是什么呢?其实ThreadLocal并非是一个线程的本地实现版本,它并不是一个Thread,而是thread local variable(线程局部变量)。也许把它命名为...

SDK4
2011/09/17
385
2
Thread(threadlocal)

1、简介 JDK 1.2的版本中就提供java.lang.ThreadLocal,ThreadLocal为解决多线程程序的并发问题提供了一种新的思路。使用这个工具类可以很简洁地编写出优美的多线程程序,ThreadLocal并不是一...

开源中国首席碉堡了
2018/11/28
93
0
ThreadLocal的那些事儿

什么是ThreadLocal? 顾名思义它是local variable(线程局部变量)。 它的功用非常简单,就是为每一个使用该变量的线程都提供一个变量值的副本,是每一个线程都可以独立地改变自己的副本,而...

陶邦仁
2012/09/07
458
3
java面试必备之ThreadLocal

按照传统的经验,如果某个对象是非线程安全的,在多线程环境下对象的访问需要采用synchronized进行同步。但是模板类并未采用线程同步机制,因为线程同步会降低系统的并发性能,此外代码同步解...

编程老司机
2018/05/16
0
0
说说 Java 的线程本地化对象容器(ThreadLocal)

JDK1.2+ 就已经提供了 java.lang.ThreadLocal 啦。可能很多小伙伴还不知道它,今天就让我们来说说它吧O(∩_∩)O~ ThreadLocal 是线程的本地化对象容器 。当在多线程环境中,使用 ThreadLoca...

deniro
2018/11/10
0
0

没有更多内容

加载失败,请刷新页面

加载更多

thinkcmf 渗透测试漏洞修复解决方案

近段时间发现很多APP程序用的是thinkcmf,此程序源码存在getshell漏洞,我们Sine安全紧急对此高危漏洞进行了分析和漏洞修复,攻击者可以通过构造特定的请求包get请求即可在远程服务器上执行任意...

网站安全
30分钟前
6
0
MySQL的IP地址与数字互转原理

一、inet_aton与inet_ntoa inet_aton是把ip地址转为数字的函数,记忆小技巧,inet表示网络相关,在c语言中a习惯性代表字符串,to就是转换的,n代表数字,aton就是字符串转数字,同理inet_nt...

trayvon
41分钟前
6
0
【翻译】全新16英寸MacBook Pro评测:开发人员的梦想成真

要问现在适合开发者用的笔记本,市面上还是有很多选择的,比如Dell的XPS系列,外星人系列(游戏也是杠杠滴),联想拯救者系列,还有形形色色的高配机型,价格也从几千到几万不等。 但是,笔吧...

Dimple91
42分钟前
8
0
IT兄弟连 HTML5教程 CSS3属性特效 CSS3分栏布局

CSS3中新出现的多列布局(multi-column)是传统HTML网页中块状布局模式的有力扩充。这种新语法能够让WEB开发人员轻松的让文本呈现多列显示。我们知道,当一行文字太长时,读者读起来就比较费劲...

老码农的一亩三分地
58分钟前
11
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部