`
king_tt
  • 浏览: 2083706 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

Java 并发专题 :FutureTask 实现预加载数据 在线看电子书、浏览器浏览网页等

 
阅读更多

继续并发专题~

FutureTask 有点类似Runnable,都可以通过Thread来启动,不过FutureTask可以返回执行完毕的数据,并且FutureTask的get方法支持阻塞。

由于:FutureTask可以返回执行完毕的数据,并且FutureTask的get方法支持阻塞这两个特性,我们可以用来预先加载一些可能用到资源,然后要用的时候,调用get方法获取(如果资源加载完,直接返回;否则继续等待其加载完成)。

下面通过两个例子来介绍下:

1、使用FutureTask来预加载稍后要用的的数据。

package com.zhy.concurrency.futuretask;

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

/**
 * 使用FutureTask来提前加载稍后要用到的数据
 * 
 * @author zhy
 * 
 */
public class PreLoaderUseFutureTask
{
	/**
	 * 创建一个FutureTask用来加载资源
	 */
	private final FutureTask<String> futureTask = new FutureTask<String>(
			new Callable<String>()
			{
				@Override
				public String call() throws Exception
				{
					Thread.sleep(3000);
					return "加载资源需要3秒";
				}
			});

	public final Thread thread = new Thread(futureTask);

	public void start()
	{
		thread.start();
	}

	/**
	 * 获取资源
	 * 
	 * @return
	 * @throws ExecutionException 
	 * @throws InterruptedException 
	 */
	public String getRes() throws InterruptedException, ExecutionException
	{
		return futureTask.get();//加载完毕直接返回,否则等待加载完毕

	}

	public static void main(String[] args) throws InterruptedException, ExecutionException
	{

		PreLoaderUseFutureTask task = new PreLoaderUseFutureTask();
		/**
		 * 开启预加载资源
		 */
		task.start();
		// 用户在真正需要加载资源前进行了其他操作了2秒
		Thread.sleep(2000);

		/**
		 * 获取资源
		 */
		System.out.println(System.currentTimeMillis() + ":开始加载资源");
		String res = task.getRes();
		System.out.println(res);
		System.out.println(System.currentTimeMillis() + ":加载资源结束");
	}

}

运行结果:

1400902789275:开始加载资源
加载资源需要3秒
1400902790275:加载资源结束
可以看到,本来加载资源的时间需要3秒,现在只花费了1秒,如果用户其他操作时间更长,则可直接返回,极大增加了用户体验。

2、看下Future的API


可以看到Future的API,还是比简单的,见名知意的感觉,get( long , TimeUnit )还能支持,设置最大等待时间,比如某个操作耗时太长,就可以取消了。

3、FutureTask模拟,用户在线观看电子书的预加载功能

用户观看当前页时,后台预先把下一页加载好,这样可以大幅度提高用户的体验,不需要每一页都等待加载,用户会觉得此电子书软件很流畅,哈哈,用户觉得好,才是真的好。

package com.zhy.concurrency.futuretask;

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


/**
 * 使用FutureTask模拟预加载下一页图书的内容
 * 
 * @author zhy
 * 
 */
public class BookInstance
{

	/**
	 * 当前的页码
	 */
	private volatile int currentPage = 1;

	/**
	 * 异步的任务获取当前页的内容
	 */
	FutureTask<String> futureTask = new FutureTask<String>(
			new Callable<String>()
			{
				@Override
				public String call() throws Exception
				{
					return loadDataFromNet();
				}
			});

	/**
	 * 实例化一本书,并传入当前读到的页码
	 * 
	 * @param currentPage
	 */
	public BookInstance(int currentPage)
	{
		this.currentPage = currentPage;
		/**
		 * 直接启动线程获取当前页码内容
		 */
		Thread thread = new Thread(futureTask);
		thread.start();
	}

	/**
	 * 获取当前页的内容
	 * 
	 * @return
	 * @throws InterruptedException
	 * @throws ExecutionException
	 */
	public String getCurrentPageContent() throws InterruptedException,
			ExecutionException
	{
		String con = futureTask.get();
		this.currentPage = currentPage + 1;
		Thread thread = new Thread(futureTask = new FutureTask<String>(
				new Callable<String>()
				{
					@Override
					public String call() throws Exception
					{
						return loadDataFromNet();
					}
				}));
		thread.start();
		return con;
	}

	/**
	 * 根据页码从网络抓取数据
	 * 
	 * @return
	 * @throws InterruptedException
	 */
	private String loadDataFromNet() throws InterruptedException
	{
		Thread.sleep(1000);
		return "Page " + this.currentPage + " : the content ....";

	}

	public static void main(String[] args) throws InterruptedException,
			ExecutionException
	{
		BookInstance instance = new BookInstance(1);
		for (int i = 0; i < 10; i++)
		{
			long start = System.currentTimeMillis();
			String content = instance.getCurrentPageContent();
			System.out.println("[1秒阅读时间]read:" + content);
			Thread.sleep(1000);
			System.out.println(System.currentTimeMillis() - start);
		}

	}
}

输出结果:

[1秒阅读时间]read:Page 1 : the content ....
2001
[1秒阅读时间]read:Page 2 : the content ....
1000
[1秒阅读时间]read:Page 3 : the content ....
1001
[1秒阅读时间]read:Page 4 : the content ....
1000
[1秒阅读时间]read:Page 5 : the content ....
1001

可以看到,除了第一次观看当前页需要等待网络加载数据的过程(输出的:2001,1000是加载耗时,1000是用户阅读时间),接下来的页面都是瞬间返回(输出的1000是用户阅读时间),完全不需要等待。

代码都是为了讲解FutureTask的应用场景,,,请勿直接在项目中使用。


好了,就到这里,欢迎各位留言。



分享到:
评论

相关推荐

    简谈java并发FutureTask的实现

    主要介绍了简谈java并发FutureTask的实现,FutureTask都是用于获取线程执行的返回结果。文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,,需要的朋友可以参考下

    Java并发编程实战

    1.1 并发简史 1.2 线程的优势 1.2.1 发挥多处理器的强大能力 1.2.2 建模的简单性 1.2.3 异步事件的简化处理 1.2.4 响应更灵敏的用户界面 1.3 线程带来的风险 1.3.1 安全性问题 1.3.2 活跃性问题 1.3.3 ...

    龙果java并发编程完整视频

    第1节你真的了解并发吗? [免费观看][免费观看] 00:27:48分钟 | 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看]...

    龙果 java并发编程原理实战

    龙果 java并发编程原理实战 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看] 00:13:03分钟 | 第4节学习并发的四...

    Java并发编程原理与实战

    从Java字节码的角度看线程安全性问题.mp4 synchronized保证线程安全的原理(理论层面).mp4 synchronized保证线程安全的原理(jvm层面).mp4 单例问题与线程安全性深入解析.mp4 理解自旋锁,死锁与重入锁.mp4 深入...

    Java 并发编程实战

    3.1.1 失效数据 3.1.2 非原子的64位操作 3.1.3 加锁与可见性 3.1.4 Volatile变量 3.2 发布与逸出 3.3 线程封闭 3.3.1 Ad-hoc线程封闭 3.3.2 栈封闭 3.3.3 ThreadLocal类 3.4 不变性 3.4.1 Final域 3.4.2...

    Java 并发编程原理与实战视频

    java并发编程原理实战 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看] 00:13:03分钟 | 第4节学习并发的四个...

    Java中Future、FutureTask原理以及与线程池的搭配使用

    主要为大家详细介绍了Java中Future、FutureTask原理以及与线程池的搭配使用,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

    Java线程池FutureTask实现原理详解

    主要介绍了Java线程池FutureTask实现原理详解,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下

    java并发编程

    第1节你真的了解并发吗? [免费观看][免费观看] 00:27:48分钟 | 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看]...

    FutureTask:FutureTask原始解析与重组-源码解析

    FutureTask原始码解析 一,FutureTask是什么? FutureTask是可取消的异步的计算任务,它可以通过线程池和线程对象执行,一般来说是FutureTask用于耗时的计算。 二,FutureTask继承图 三,未来任务源码 FutureTask的...

    比较java中Future与FutureTask之间的关系

    在本篇文章里我们给大家分享了java中Future与FutureTask之间的关系的内容,有需要的朋友们可以跟着学习下。

    Java并发编程与高并发解决方案

    Java并发编程与高并发解决方案:线程池,消息队列,服务拆分,限流,降级,熔断思路,数据库分表

    Java并发编程(学习笔记).xmind

    Java并发编程 背景介绍 并发历史 必要性 进程 资源分配的最小单位 线程 CPU调度的最小单位 线程的优势 (1)如果设计正确,多线程程序可以通过提高处理器资源的利用率来提升系统吞吐率 ...

    Java并发包源码分析(JDK1.8)

    Java并发包源码分析(JDK1.8):囊括了java.util.concurrent包中大部分类的源码分析,其中涉及automic包,locks包(AbstractQueuedSynchronizer、ReentrantLock、ReentrantReadWriteLock、LockSupport等),queue...

    Java 多线程与并发(17-26)-JUC线程池- FutureTask详解.pdf

    Java 多线程与并发(17_26)-JUC线程池_ FutureTask详解

    java8源码-concurrency:java并发总结

    java8 源码 Java 并发多线程从简到全 参考: 目录: [TOC] 相关文档: kwseeker/netty Executors线程池.md 1 基本概念 1.1 CPU与线程的关系 1.2 线程与进程的区别和关系 1.3 吞吐量 1.4 线程安全 1.5 线程声明周期 ...

Global site tag (gtag.js) - Google Analytics