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

本文主要是介绍Java 并发专题 FutureTask 实现预加载数据 在线看电子书 浏览器浏览网页等,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

分享一下我老师大神的人工智能教程。零基础!通俗易懂!风趣幽默!还带黄段子!希望你也加入到我们人工智能的队伍中来!https://blog.csdn.net/jiangjunshow

继续并发专题~

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:开始加载资源加载资源需要31400902790275:加载资源结束
可以看到,本来加载资源的时间需要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的应用场景,,,请勿直接在项目中使用。


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




           

分享一下我老师大神的人工智能教程。零基础!通俗易懂!风趣幽默!还带黄段子!希望你也加入到我们人工智能的队伍中来!https://blog.csdn.net/jiangjunshow

这篇关于Java 并发专题 FutureTask 实现预加载数据 在线看电子书 浏览器浏览网页等的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/365430

相关文章

Python中pywin32 常用窗口操作的实现

《Python中pywin32常用窗口操作的实现》本文主要介绍了Python中pywin32常用窗口操作的实现,pywin32主要的作用是供Python开发者快速调用WindowsAPI的一个... 目录获取窗口句柄获取最前端窗口句柄获取指定坐标处的窗口根据窗口的完整标题匹配获取句柄根据窗口的类别匹配获取句

Maven中引入 springboot 相关依赖的方式(最新推荐)

《Maven中引入springboot相关依赖的方式(最新推荐)》:本文主要介绍Maven中引入springboot相关依赖的方式(最新推荐),本文给大家介绍的非常详细,对大家的学习或工作具有... 目录Maven中引入 springboot 相关依赖的方式1. 不使用版本管理(不推荐)2、使用版本管理(推

Java 中的 @SneakyThrows 注解使用方法(简化异常处理的利与弊)

《Java中的@SneakyThrows注解使用方法(简化异常处理的利与弊)》为了简化异常处理,Lombok提供了一个强大的注解@SneakyThrows,本文将详细介绍@SneakyThro... 目录1. @SneakyThrows 简介 1.1 什么是 Lombok?2. @SneakyThrows

在 Spring Boot 中实现异常处理最佳实践

《在SpringBoot中实现异常处理最佳实践》本文介绍如何在SpringBoot中实现异常处理,涵盖核心概念、实现方法、与先前查询的集成、性能分析、常见问题和最佳实践,感兴趣的朋友一起看看吧... 目录一、Spring Boot 异常处理的背景与核心概念1.1 为什么需要异常处理?1.2 Spring B

python处理带有时区的日期和时间数据

《python处理带有时区的日期和时间数据》这篇文章主要为大家详细介绍了如何在Python中使用pytz库处理时区信息,包括获取当前UTC时间,转换为特定时区等,有需要的小伙伴可以参考一下... 目录时区基本信息python datetime使用timezonepandas处理时区数据知识延展时区基本信息

Python位移操作和位运算的实现示例

《Python位移操作和位运算的实现示例》本文主要介绍了Python位移操作和位运算的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 位移操作1.1 左移操作 (<<)1.2 右移操作 (>>)注意事项:2. 位运算2.1

如何在 Spring Boot 中实现 FreeMarker 模板

《如何在SpringBoot中实现FreeMarker模板》FreeMarker是一种功能强大、轻量级的模板引擎,用于在Java应用中生成动态文本输出(如HTML、XML、邮件内容等),本文... 目录什么是 FreeMarker 模板?在 Spring Boot 中实现 FreeMarker 模板1. 环

Qt实现网络数据解析的方法总结

《Qt实现网络数据解析的方法总结》在Qt中解析网络数据通常涉及接收原始字节流,并将其转换为有意义的应用层数据,这篇文章为大家介绍了详细步骤和示例,感兴趣的小伙伴可以了解下... 目录1. 网络数据接收2. 缓冲区管理(处理粘包/拆包)3. 常见数据格式解析3.1 jsON解析3.2 XML解析3.3 自定义

SpringMVC 通过ajax 前后端数据交互的实现方法

《SpringMVC通过ajax前后端数据交互的实现方法》:本文主要介绍SpringMVC通过ajax前后端数据交互的实现方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价... 在前端的开发过程中,经常在html页面通过AJAX进行前后端数据的交互,SpringMVC的controll

Java中的工具类命名方法

《Java中的工具类命名方法》:本文主要介绍Java中的工具类究竟如何命名,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录Java中的工具类究竟如何命名?先来几个例子几种命名方式的比较到底如何命名 ?总结Java中的工具类究竟如何命名?先来几个例子JD