`
gzcj
  • 浏览: 289814 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

jdk5.0 多线程学习笔记(八)

阅读更多

    前面已经介绍过future模式和jdk5中的future,在jdk5中对future有个基本实现,这个实现就是类futuretask。

对于future模式,每个人都有自己的理解。这里引用他人的话,做个理解:

Future 模式就是在主线程中当需要进行比较耗时的作业,但不想阻塞主线程的作业时,将耗时作业交由 Future 对象在后台中完成,当主线程将来(这个 Future 的意义也就体现在这里了)需要时即可通过 Future 对象获得已经作业对象。

 

下面举个例子,来加深理解,:)其实,看代码容易理解。

import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class testFutureTask {
	public static void main(String[] args) {
		// Init callable object and future task
		Callable pAccount = new PrivateAccount();
		FutureTask futureTask = new FutureTask(pAccount);

		// Create a new thread to do so
		Thread pAccountThread = new Thread(futureTask);
//this will call the method call of PrivateAccount		
pAccountThread.start();

		// Do something else in the main thread
		System.out.println(" Doing something else here. ");

		// Get the total money from other accounts
		int totalMoney = new Random().nextInt(100000);
		System.out.println(" You have  " + totalMoney
				+ "  in your other Accounts. ");
		System.out.println(" Waiting for data from Private Account ");
		// If the Future task is not finished, we will wait for it
		while (!futureTask.isDone()) {
			try {
				Thread.sleep(5);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		Integer privataAccountMoney = null;
		// Since the future task is done, get the object back
		try {
			privataAccountMoney = (Integer) futureTask.get();
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (ExecutionException e) {
			e.printStackTrace();
		}
		System.out.println(" The total moeny you have is  "
				+ (totalMoney + privataAccountMoney.intValue()));
	}

}

 

import java.util.Random;
import java.util.concurrent.Callable;

public class PrivateAccount implements Callable {
	Integer totalMoney;

	public Integer call() throws Exception {
		// Simulates a time conusimg task, sleep for 10s
		Thread.sleep(10000);
		totalMoney = new Integer(new Random().nextInt(10000));
		System.out.println(" You have  " + totalMoney
				+ "  in your private Account. ");
		return totalMoney;
	}

}

 

从上面的代码可以看出有了futuretask,利用future模式完成任务还是很方便的。

分享到:
评论

相关推荐

    良葛格JDK5.0学习笔记

    10. **线程并发库**:JDK5.0引入了`java.util.concurrent`包,提供了如`ExecutorService`、`Future`、`Semaphore`等高级并发工具,简化了多线程编程。 通过深入学习《良葛格JDK5.0学习笔记》,开发者能够全面了解并...

    良葛格Java JDK 5.0学习笔记

    JDK 5.0加强了对多线程的支持,提供了一些新的工具,如jstack,用于分析线程状态,帮助开发者调试和解决死锁等问题。 十、内省增强(Introspection Enhancements) Java反射API在JDK 5.0中得到了增强,提供了对泛型...

    良葛格Java JDK 5.0学习笔记.rar

    《良葛格Java JDK 5.0学习笔记》是一份详尽的教程资源,旨在帮助开发者深入理解并掌握Java开发工具包(Java Development Kit)的第5个主要版本——JDK 5.0。这份笔记涵盖了JDK 5.0中的核心特性、改进和新功能,是...

    良葛格java jdk 5.0学习笔记

    《良葛格Java JDK 5.0学习笔记》是一份专为Java初学者及爱好者精心编写的教程,它深入浅出地介绍了Java编程语言的核心概念和技术。这份教材以JDK 5.0版本为基础,该版本是Java发展史上的一个重要里程碑,引入了许多...

    良葛格Java JDK 5.0学习笔记fuluB

    9. **并发编程改进**:JDK 5.0引入了并发工具类,如`java.util.concurrent`包下的`ExecutorService`、`Future`、`Semaphore`等,以及`ThreadLocal`,增强了多线程编程的能力。 10. **内省(Introspection)**:JDK ...

    java jdk5.0学习笔记——良葛格

    良葛格的《Java JDK5.0学习笔记》是一本面向初学者的教程,旨在帮助读者掌握这个版本的核心概念和技术。以下是基于该书部分内容的知识点详解: 1. **泛型**:JDK 5.0引入了泛型,这是一种强大的类型系统增强,允许...

Global site tag (gtag.js) - Google Analytics