前面已经介绍过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模式完成任务还是很方便的。
分享到:
相关推荐
10. **线程并发库**:JDK5.0引入了`java.util.concurrent`包,提供了如`ExecutorService`、`Future`、`Semaphore`等高级并发工具,简化了多线程编程。 通过深入学习《良葛格JDK5.0学习笔记》,开发者能够全面了解并...
JDK 5.0加强了对多线程的支持,提供了一些新的工具,如jstack,用于分析线程状态,帮助开发者调试和解决死锁等问题。 十、内省增强(Introspection Enhancements) Java反射API在JDK 5.0中得到了增强,提供了对泛型...
《良葛格Java JDK 5.0学习笔记》是一份详尽的教程资源,旨在帮助开发者深入理解并掌握Java开发工具包(Java Development Kit)的第5个主要版本——JDK 5.0。这份笔记涵盖了JDK 5.0中的核心特性、改进和新功能,是...
《良葛格Java JDK 5.0学习笔记》是一份专为Java初学者及爱好者精心编写的教程,它深入浅出地介绍了Java编程语言的核心概念和技术。这份教材以JDK 5.0版本为基础,该版本是Java发展史上的一个重要里程碑,引入了许多...
9. **并发编程改进**:JDK 5.0引入了并发工具类,如`java.util.concurrent`包下的`ExecutorService`、`Future`、`Semaphore`等,以及`ThreadLocal`,增强了多线程编程的能力。 10. **内省(Introspection)**:JDK ...
良葛格的《Java JDK5.0学习笔记》是一本面向初学者的教程,旨在帮助读者掌握这个版本的核心概念和技术。以下是基于该书部分内容的知识点详解: 1. **泛型**:JDK 5.0引入了泛型,这是一种强大的类型系统增强,允许...