文档章节

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

侠客人生
 侠客人生
发布于 2017/07/27 15:34
字数 975
阅读 7
收藏 0

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

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

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

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

 

package com.jhaso.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的应用场景,,,请勿直接在项目中使用。

本文转载自:http://blog.csdn.net/lmj623565791/article/details/26817403

共有 人打赏支持
侠客人生
粉丝 15
博文 43
码字总数 82954
作品 0
朝阳
私信 提问
【Java并发专题】27篇文章详细总结Java并发基础知识

努力的意义,就是,在以后的日子里,放眼望去全是自己喜欢的人和事! github:https://github.com/CL0610/Java-concurrency,欢迎题issue和Pull request。所有的文档都是自己亲自码的,如果觉...

你听___
05/06
0
0
TeaVM 现已支持将 Java 字节码编译成 WebAssembly

TeaVM 是一个 AOT 编译器(翻译器),可将 JVM 字节码翻译成 JavaScript,它和著名的 GWT 有一定相似之处,但必须指出 TeaVM 并不需要 Java 源代码,而只需要 class 文件(JVM 字节码)。所以...

局长
01/06
3.1K
12
【并发编程】Future模式及JDK中的实现

1.1、Future模式是什么 先简单举个例子介绍,当我们平时写一个函数,函数里的语句一行行同步执行,如果某一行执行很慢,程序就必须等待,直到执行结束才返回结果;但有时我们可能并不急着需要...

weknow
09/01
0
2
玩大数据一定用得到的19款 Java 开源 Web 爬虫

网络爬虫(又被称为网页蜘蛛,网络机器人,在FOAF社区中间,更经常的称为网页追逐者),是一种按照一定的规则,自动地抓取万维网信息的程序或者脚本。另外一些不常使用的名字还有蚂蚁、自动索引...

两味真火
2016/09/23
15.4K
12
android简单网页浏览器的开发

android简单网页浏览器的开发 @author:郑海波 http://blog.csdn.net/nuptboyzhb/ 功能概要: 1.用WebView控件实现简单浏览器的开发 2.实现了网页浏览器的简单功能。 3.能够浏览网页中的所有...

长平狐
2012/10/08
2.8K
0

没有更多内容

加载失败,请刷新页面

加载更多

自定义 Maven 的 repositories

有时,应用中需要一些比较新的依赖,而这些依赖并没有正式发布,还是处于milestone或者是snapshot阶段,并不能从中央仓库或者镜像站上下载到。此时,就需要 自定义Maven的<repositories>。 ...

waylau
7分钟前
0
0
徒手写一个es6代码库

mkdir democd demonpm initnpm install -g babelnpm install -g babel-clinpm install --save-dev babel-preset-es2015-node5 在项目目录创建两个文件夹 functional-playground ......

lilugirl
7分钟前
0
0
linux定位应用问题的一些常用命令,特别针对内存和线程分析的dump命令

1.jps找出进程号,找到对应的进程号后面才好继续操作 2.linux查看进程详细信息 ps -ef | grep 进程ID 3. dump内存信息 Jmap -dump:format=b,file=YYMMddhhmm.dump pid 4.top查看cpu占用信息 ...

noob_chr
7分钟前
0
0
Android TV开发-按键焦点

写在前面 按键焦点过程了解 2.1 dispatchKeyEvent 过程了解 2.2 焦点查找请求过程了解 1.2.1 第一次获取焦点 1.2.3 按键焦点 焦点控制 焦点记忆 应用场景 参考资料 [TOC] 1. 写在前面 工...

冰雪情缘l
7分钟前
0
0
java框架学习日志-3

这章主要是补充一些ioc创建对象的方式,ioc容器在写好<bean></bean>的时候就已经创建对象了。在之前的例子中,一直都是无参的构造方法。下面给出有参的构造方法的对象的创建,没有什么难点重...

白话
10分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部