`
zha_zi
  • 浏览: 592413 次
  • 性别: Icon_minigender_1
  • 来自: 西安
社区版块
存档分类
最新评论

Future 模式详解(并发使用)

 
阅读更多

 

  我觉得很多讲Future模式的文章并没有深刻理解Future模式,其实Future模式只是生产者-消费者模型的扩展。经典“生产者-消费者”模型中消息的生产者不关心消费者何时处理完该条消息,也不关心处理结果。Future模式则可以让消息的生产者等待直到消息处理结束,如果需要的话还可以取得处理结果

 

用过Java并发包的朋友或许对Future (interface) 已经比较熟悉了,其实Future 本身是一种被广泛运用的并发设计模式,可在很大程度上简化需要数据流同步的并发应用开发。在一些领域语言(如Alice ML )中甚至直接于语法层面支持Future。

这里就以java.util.concurrent.Future 为例简单说一下Future的具体工作方式。Future对象本身可以看作是一个显式的引用,一个对异步处理结果的引用。由于其异步性质,在创建之初,它所引用的对象可能还并不可用(比如尚在运算中,网络传输中或等待中)。这时,得到Future的程序流程如果并不急于使用Future所引用的对象,那么它可以做其它任何想做的事儿,当流程进行到需要Future背后引用的对象时,可能有两种情况:

  • 希望能看到这个对象可用,并完成一些相关的后续流程。如果实在不可用,也可以进入其它分支流程。
  • “没有你我的人生就会失去意义,所以就算海枯石烂,我也要等到你。”(当然,如果实在没有毅力枯等下去,设一个超时也是可以理解的)

对于前一种情况,可以通过调用Future.isDone()判断引用的对象是否就绪,并采取不同的处理;而后一种情况则只需调用get()或
get(long timeout, TimeUnit unit)通过同步阻塞方式等待对象就绪。实际运行期是阻塞还是立即返回就取决于get()的调用时机和对象就绪的先后了。

简单而言,Future模式可以在连续流程中满足数据驱动的并发需求,既获得了并发执行的性能提升,又不失连续流程的简洁优雅。

但是Futrue模式有个重大缺陷:当消费者工作得不够快的时候,它会阻塞住生产者线程,从而可能导致系统吞吐量的下降。所以不建议在高性能的服务端使用。


java.util.concurrent.Callable与java.util.concurrent.Future类可以协助您完成Future模式。Future模式在请求发生时,会先产生一个Future对象给发出请求的客户。它的作用类似于代理(Proxy)对象,而同时所代理的真正目标对象的生成是由一个新的线程持续进行。真正的目标对象生成之后,将之设置到Future之中,而当客户端真正需要目标对象时,目标对象也已经准备好,可以让客户提取使用

Callable是一个接口,与Runnable类似,包含一个必须实现的方法,可以启动为让另一个线程来执行。不过Callable工作完成后,可以传回结果对象。Callable接口的定义如下:

 

public interface Callable<V> { 
            V call() throws Exception; 
} 

 可以使用Callable完成某个费时的工作,工作结束后传回结果对象,例如求质数

 

 

PrimeCallable.java 

package onlyfun.caterpillar; 
import java.util.ArrayList; 
            import java.util.List; 
            import java.util.concurrent.Callable; 


public class PrimeCallable implements Callable<int[]> { 
private int max; 

public PrimeCallable(int max) { 
this.max = max; 
} 

public int[] call() throws Exception { 
int[] prime = new int[max+1]; 

List<Integer> list = new ArrayList<Integer>(); 



for(int i = 2; i <= max; i++) 
prime[i] = 1; 



for(int i = 2; i*i <= max; i++) { // 这里可以改进 
if(prime[i] == 1) { 
for(int j = 2*i; j <= max; j++) { 
if(j % i == 0) 
prime[j] = 0; 
} 
} 
} 



for(int i = 2; i < max; i++) { 
if(prime[i] == 1) { 
list.add(i); 
} 
} 

int[] p = new int[list.size()]; 
for(int i = 0; i < p.length; i++) { 
p[i] = list.get(i).intValue(); 
} 

return p; 
} 
} 
 

 

程序中的求质数方法是很简单的,但效率不好,这里只是为了示范方便,才使用简单的求质数方法,要更有效率地求质数

假设现在求质数的需求是在启动PrimeCallable后的几秒之后,则可以使用Future来获得Callable执行的结果,从而在未来的时间点获得结果

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

public class FutureDemo {
	public static void main(String[] args) {
		Callable<int[]> primeCallable = new PrimeCallable(1000);
		FutureTask<int[]> primeTask = new FutureTask<int[]>(primeCallable);
		Thread t = new Thread(primeTask);
		t.start();
		try {
			// 假设现在做其他事情
			Thread.sleep(5000);
			// 回来看看质数找好了吗
			if (primeTask.isDone()) {
				int[] primes = primeTask.get();
				for (int prime : primes) {
					System.out.print(prime + " ");
				}
				System.out.println();
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (ExecutionException e) {
			e.printStackTrace();
		}
	}
}

 java.util.concurrent.FutureTask是一个代理,真正执行找质数功能的是Callable对象。使用另一个线程启动FutureTask,之后就可以做其他的事了。等到某个时间点,用isDone()观察任务是否完成,如果完成了,就可以获得结果。一个执行结果如下,显示所有找到的质数: 

2 3 5 7 11 13 17 19 23 29 31 37 41 43 47 53 59 61 
            67 71 73 79 83 89 97 101 103 107 109 113 127 131 
            137 139 149 151 157 163 167 173 179 181 191 193 
            197 199 211 223 227 229 233 239 241 251 257 263 
            269 271 277 281 283 293 307 311 313 317 331 337 
            347 349 353 359 367 373 379 383 389 397 401 409 
            419 421 431 433 439 443 449 457 461 463 467 479 
            487 491 499 503 509 521 523 541 547 557 563 569 
            571 577 587 593 599 601 607 613 617 619 631 641 
            643 647 653 659 661 673 677 683 691 701 709 719 
            727 733 739 743 751 757 761 769 773 787 797 809 
            811 821 823 827 829 839 853 857 859 863 877 881 
            883 887 907 911 919 929 937 941 947 953 967 971 
            977 983 991 997 

用户可能需要快速翻页浏览文件,但在浏览到有图片的页数时,由于图片文件很大,导致图片加载较慢,造成用户浏览文件时会有停顿的现象。因此希望在文件开启之后,仍有一个后台作业持续加载图片。这样,用户在快速浏览页面时,所造成的停顿可以获得改善,从而可以考虑使用这里所介绍的功能 

 

分享到:
评论

相关推荐

    31 凭票取餐—Future模式详解.pdf

    【31 凭票取餐—Future模式详解】 在Java并发编程中,Future模式是一种常见的设计模式,它允许主线程在不阻塞的情况下启动一个异步任务,然后在需要时获取任务的结果。Future模式的灵感来源于现实生活中的场景,如...

    Java高并发程序设计模式资料

    在Java编程领域,高并发程序设计模式是解决系统性能瓶颈、提升系统响应速度和处理能力的关键技术。这一主题涵盖了多线程、并发控制、同步机制、分布式架构等多个方面。以下是对这一主题的详细阐述: 1. **并发基础*...

    java多线程设计模式详解

    Java多线程设计模式是Java编程中不可或缺的一部分,它涉及到如何在并发环境下高效、安全地组织代码...阅读提供的"java多线程设计模式详解.pdf"和"Java多线程设计模式源码"文件,将能更深入地理解这些模式的实际运用。

    java多线程设计模式详解.pdf

    标题“java多线程设计模式详解.pdf”中提到的知识点是关于Java多线程编程中设计模式的应用。Java多线程是并发编程的重要组成部分,设计模式则是软件工程中用于解决特定问题的最佳实践。将两者结合起来,意味着此文件...

    java多线程设计模式详解(PDF及源码)

    (注意,本资源附带书中源代码可供参考) 多线程与并发处理是程序设计好坏优劣的重要课题,本书通过浅显易懂的文字与实例来介绍Java线程相关的设计模式概念,并且通过实际的Java程序范例和 UML图示来一一解说,书中...

    Spring Boot对Future模式的支持详解

    Spring Boot对Future模式的支持使得开发者可以更方便地在应用程序中实现异步处理,从而提高系统的并发性能和响应速度。在实际开发中,当遇到需要执行耗时操作或复杂计算时,我们可以利用多线程来提升效率,而Future...

    汪文君高并发编程实战视频资源下载.txt

    │ 高并发编程第二阶段28讲、使用ThreadLocal重新实现一个上下文设计模式.mp4 │ 高并发编程第二阶段29讲、多线程Balking设计模式-上.mp4 │ 高并发编程第二阶段30讲、多线程Balking设计模式-下.mp4 │ 高并发...

    Java并发编程:设计原则与模式(第二版).rar

    《Java并发编程:设计原则与模式(第二版)》是一本深入探讨Java平台上的多线程和并发编程的著作。本书旨在帮助开发者理解和掌握在Java环境中进行高效并发处理的关键技术与设计模式。以下是对该书内容的一些核心知识...

    并发设计模式

    - Future模式:异步执行任务并返回结果,提供了一种机制来获取异步任务的结果。 - 生产者消费者模式:管理不同线程之间的数据交换。 #### 三、单例模式详解 单例模式是一种常用的创建型设计模式,它确保一个类...

    JAVA高质量并发详解,多线程并发深入讲解

    ### JAVA高质量并发详解知识点概述 #### 一、Java并发编程基础 - **基础知识:** - **线程基本概念:** Java线程是程序执行流的最小单元,一个线程包含一个程序计数器(PC)、虚拟机栈、本地方法栈、线程私有的工作...

    java多线程设计模式详解+源码

    Java多线程设计模式是Java...通过阅读“java多线程设计模式详解”文档和分析源码,你将掌握如何在Java项目中高效地使用多线程,解决并发编程中的各种问题,提升程序的性能和稳定性。这是一份值得深入研究的宝贵资料。

    java多线程设计模式详解PDF及源码

    本资源包括了详细的“Java多线程设计模式详解”PDF文档以及配套的源码,帮助开发者深入理解和应用这些模式。 首先,我们要了解Java中创建线程的几种方式:继承Thread类、实现Runnable接口以及使用ExecutorService和...

    13-Java并发编程学习宝典.zip

    6. **Future模式** - "31 凭票取餐—Future模式详解-慕课专栏.html":讲解了`Future`接口和`FutureTask`类,它们用于获取异步任务的结果。 7. **Master-Slave模式** - "36 为多线程们安排一位经理—Master-Slave...

    Java并发编程原理与实战

    Future设计模式实现(实现类似于JDK提供的Future).mp4 Future源码解读.mp4 ForkJoin框架详解.mp4 同步容器与并发容器.mp4 并发容器CopyOnWriteArrayList原理与使用.mp4 并发容器ConcurrentLinkedQueue原理与使用....

    java多线程高级设计模式详解

    Java多线程高级设计模式详解 在Java编程中,多线程是不可或缺的一部分,它能够充分利用多核处理器的计算能力,提高程序的并发性能。本文将深入探讨Java多线程中的高级设计模式,帮助开发者更好地理解和应用这些模式...

    java多线程设计模式详解.rar

    6. **future模式**:`Future`接口和`Callable`接口一起使用,可以异步执行任务并获取结果。这在等待某个耗时操作完成,而不阻塞当前线程的情况下非常有用。 7. **线程间通信模式**:`wait()`、`notify()`和`...

Global site tag (gtag.js) - Google Analytics