文档章节

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

侠客人生
 侠客人生
发布于 2017/07/27 15:34
字数 975
阅读 5
收藏 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
【并发编程】Future模式及JDK中的实现

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

weknow
09/01
0
2
java并发编程——FutureTask源码分析

FutureTask的简单示例: FutureTask的应用场景,如果在当前线程中需要执行比较耗时的操作,但又不想阻塞当前线程时,可以把这些作业交给FutureTask,另开一个线程在后台完成,当当前线程将来...

长头发-dawn
09/07
0
0
Java程序员面试大纲—错过了金三银四,你还要错过2018吗?

跳槽时时刻刻都在发生,但是我建议大家跳槽之前,先想清楚为什么要跳槽。切不可跟风,看到同事一个个都走了,自己也盲目的开始面试起来(期间也没有准备充分),到底是因为技术原因(影响自己...

java高级架构牛人
04/27
0
0
WebView!!!!日记~~

● Android设备多分辨率的问题 Android浏览器默认预览模式浏览 会缩小页面 WebView中则会以原始大小显示 Android浏览器和WebView默认为mdpi。hdpi相当于mdpi的1.5倍 ldpi相当于0.75倍 三种解...

Neo_
2012/11/01
0
0

没有更多内容

加载失败,请刷新页面

加载更多

VS code编辑器安装 php7.2 NTS 版本 Xdebug

本文使用的是 phpstudy 一键安装包(windows32位) php 版本是 php7.2 NTS 1、在 phpstudy 面板中开启 phpdebug 扩展 // 其他选项菜单-> php 扩展与设置-> php 扩展 2、官方下载 Xdebug // ...

削个椰子皮_给个梨
6分钟前
0
0
Swagger中配置了@ApiModelProperty的allowableValues属性但不显示的问题

现在用Swagger来生成API文档的例子已经非常多了,今天碰到开发同事问了一个问题,帮着看了一下,主要还是配置方法的问题,所以记录一下。如果您也碰到了同样的问题,希望本文对您有用。 问题...

程序猿DD
36分钟前
1
0
sql 命令

show variables like '%general%'; show variables like '%log_output%'; show variables like '%quer%'; show global status like '%slow%';...

JavaSon712
44分钟前
2
0
Django修改默认数据库引擎

Django默认数据库引擎为sqlite3,除了sqlite3,还支持postgresql、mysql、oracle 配置如下:其中postgresql_psycopg2为postgresql的适配器。 'django.db.backends.postgresql' 'django.db.bac......

MichaelShu
49分钟前
0
0
动画源码解析

目录介绍 1.Animation和Animator区别 2.Animation运行原理和源码分析 2.1 基本属性介绍 2.2 如何计算动画数据 2.3 什么是动画更新函数 2.4 动画数据如何存储 2.5 Animation的调用 3.Animator...

潇湘剑雨
55分钟前
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部