Java FutureTask示例程序

有时我写了一篇有关Java Callable Future接口的文章,我们可以使用它来获得线程的并发处理优势,以及它们能够将值返回给调用程序。

FutureTask是Future接口的基础具体实现,并提供异步处理。 它包含启动和取消任务的方法,以及可以返回FutureTask状态(完成还是取消)的方法。 我们需要一个可调用的对象来创建未来的任务,然后我们可以使用Java线程池执行器来异步处理这些任务。

让我们看一个带有简单程序的FutureTask示例。

由于FutureTask需要可调用对象,因此我们将创建一个简单的Callable实现。

package com.journaldev.threads;import java.util.concurrent.Callable;public class MyCallable implements Callable<String> {private long waitTime;public MyCallable(int timeInMillis){this.waitTime=timeInMillis;}@Overridepublic String call() throws Exception {Thread.sleep(waitTime);//return the thread name executing this callable taskreturn Thread.currentThread().getName();}}

这是FutureTask方法的示例,它显示了FutureTask的常用方法。

package com.journaldev.threads;import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;public class FutureTaskExample {public static void main(String[] args) {MyCallable callable1 = new MyCallable(1000);MyCallable callable2 = new MyCallable(2000);FutureTask<String> futureTask1 = new FutureTask<String>(callable1);FutureTask<String> futureTask2 = new FutureTask<String>(callable2);ExecutorService executor = Executors.newFixedThreadPool(2);executor.execute(futureTask1);executor.execute(futureTask2);while (true) {try {if(futureTask1.isDone() && futureTask2.isDone()){System.out.println("Done");//shut down executor serviceexecutor.shutdown();return;}if(!futureTask1.isDone()){//wait indefinitely for future task to completeSystem.out.println("FutureTask1 output="+futureTask1.get());}System.out.println("Waiting for FutureTask2 to complete");String s = futureTask2.get(200L, TimeUnit.MILLISECONDS);if(s !=null){System.out.println("FutureTask2 output="+s);}} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}catch(TimeoutException e){//do nothing}}}}

当我们在上面的程序上运行时,您会注意到它一段时间不打印任何内容,因为FutureTask的get()方法等待任务完成,然后返回输出对象。 还有一个重载方法也只能等待指定的时间,我们将它用于futureTask2。 还要注意,使用isDone()方法可确保在执行所有任务后终止程序。

上面程序的输出将是:

FutureTask1 output=pool-1-thread-1
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
FutureTask2 output=pool-1-thread-2
Done

因此,FutureTask没有任何好处,但是当我们想要重写某些Future接口方法并且不想实现Future接口的每个方法时,它就派上用场了。

参考: 开发者食谱博客上来自我们JCG合作伙伴 Pankaj Kumar的Java FutureTask示例程序 。

翻译自: https://www.javacodegeeks.com/2013/07/java-futuretask-example-program.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/368211.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java 日期类代码_java 日期时间处理类

import java.util.Calendar;import java.sql.Date;import java.text.SimpleDateFormat;import java.text.ParseException;/*** Utility to date time* version 0.1* author Super Zhao*/public class DateTimeUtil{/*** 由java.util.Date到java.sql.Date的类型转换* param date…

搭建SSH框架–使用篇

创建如下包&#xff1a; action用于响应请求 service则是提供请求的操作 dao用于操作数据库 entity用于映射数据库表 打开DB Browser –> personalCD&#xff08;创建篇的数据库连接&#xff09;–> SCOTT –> TABLE –> t_USER –> 右键Hibernate Reverse……

Hadoop HA集群的搭建

HA 集群搭建的难度主要在于配置文件的编写&#xff0c; 心细&#xff0c;心细&#xff0c;心细&#xff01; ha模式下&#xff0c;secondary namenode节点不存在... 集群部署节点角色的规划&#xff08;7节点&#xff09;------------------server01   namenode   zkfcserv…

3个简单步骤即可测试Java 8

即将发布的Java 8版本为Java开发人员带来了许多新功能&#xff0c;但是升级时始终存在代码破裂的风险。 我们都记得Java 7发行时有一系列非常严重的错误 。 当然&#xff0c;我们所有人都可以帮助避免在Java 8中出现相同的问题。我今天要介绍的方法是使用现有的Continuous Int…

php接收get参数false是字符串,php解析url (parse_url) 参数成数组 (parse_str)

php解析url (parse_url) 参数成数组 (parse_str)(1)parse_url (PHP 4, PHP 5) — 解析 URL&#xff0c;返回其组成部分&#xff0c;函数原型如下&#xff1a;mixed parse_url ( string $url [, int $component -1 ] )本函数解析一个 URL 并返回一个关联数组&#xff0c;包含在…

父类div高度适应子类div

父类div高度适应子类div 通常有许多div的高度由子类的高度决定父类的高度&#xff0c;所以需要父类div要适应子类div的高度&#xff0c;一般情况父类的高度可以直接设置成“auto”即可。 在有的情况下&#xff0c;子类div会撑破父类div. 所以需要走一些调整。通常有3种方法对…

Android - RecyclerView

0.添加引用 compile com.android.support:recyclerview-v7:23.4.0 命名空间&#xff1a; android.support.v7.widget.RecyclerView android.support.v7.widget.LinearLayoutManager 1.首先添加控件 <android.support.v7.widget.RecyclerViewandroid:id"id/activity_re…

jenkins jar包上传maven仓库

1 Jenkins 编译后部署至 Maven 仓库jenkins编译后构件&#xff08;如&#xff1a;jar包&#xff09;部署至maven仓库需修改以下内容&#xff1a;maven 仓库配置&#xff1b;项目 pom 文件&#xff1b;本地仓库的 settings.xml 内容&#xff1b;jenkins goals 修改1&#x…

Java文件合并变得语义化

与任何程序员交谈&#xff0c;并询问他应该如何进行合并&#xff1a;“它应该理解代码&#xff0c;对其进行解析&#xff0c;然后根据结构进行合并” –他很可能会说。 而这恰恰是SemanticMerge for Java所做的&#xff1a;它解析要合并的文件&#xff08;加上祖先或“文件在更…

eval函数

#! /usr/bin/env python# -*- coding: utf-8 -*-# __author__ "Deakin"# Email: 469792427qq.com# Date: 2018/1/14#1. 运行程序输出第一级菜单#2. 选择一级菜单某项&#xff0c;输出二级菜单&#xff0c;同理输出三级菜单#3. 菜单数据保存在文件中#4. 让用户选择是…

KnockoutJS-快速入门

虽然在WPF中接触过MVVM模式&#xff0c;可是刚开始在Web中接触到Knockout.JS让我大吃一惊&#xff0c;简化了好多工作量&#xff0c;原来可能需要一大堆的JS脚本完成的工作量&#xff0c;被释放许多。接触KnockoutJS一年多了&#xff0c;在好多个项目中也用到过&#xff0c;虽然…

几道web前端练习题目

在 HTML 语言中&#xff0c;以下哪个属性不是通用属性&#xff1f;A]<class>B]<title>C]<href>D]<style> 在线练习&#xff1a;http://hovertree.com/tiku/bjaf/qi1g37nf.htm 在 CSS 样式定义中&#xff0c;以下哪种 RGB 颜色值是 Web 安全色&#xf…

php如何导入数据,““php中如何将execl的数据导入到数据库中

php中如何将execl的数据导入到数据库中1.使用PHPExcel Parser Pro&#xff0c;但是这个软件为收费软件&#xff1b;2.可EXCEL表保存为CSV&#xff0c;然后通过phpmyadmin或者SQLyog导入&#xff0c;SQLyog导入的方法为&#xff1a;将EXCEL表另存为CSV形式&#xff1b;打开SQLyo…

Spring MVC错误处理流程

使用Spring MVC可以通过三种方式处理异常流&#xff0c;其目的是拦截任何应用程序异常&#xff0c;并向用户提供友好而信息丰富的视图。 1.在web.xml文件中使用error-page标记&#xff1a; 这是servlet规范驱动的方法&#xff0c;其中基于HTTP响应代码或异常类型来拦截从应用程…

Busybox下tftp命令使用详解

参数说明&#xff1a;-l 是local的缩写&#xff0c;后跟存在于Client的源文件名&#xff0c;或下载Client后 重命名的文件名。 -r 是remote的缩写&#xff0c;后跟Server即PC机tftp服务器根目录中的源文 件名&#xff0c;或上传Se…

php 获取sql字段名,php – 使用DISTINCT和UNION在SQL查询中获取字段名称

我有以下查询&#xff1a;SELECT DISTINCT(uniq)FROM(SELECT sex AS uniq FROM type4UNIONSELECT fason AS uniq FROM type4UNIONSELECT color AS uniq FROM type4UNIONSELECT size AS uniq FROM type4) AS Temp它运作得很好,它返回&#xff1a;[uniq] > some unique value是…

OC学习笔记——基础控件篇

因为之前做iOS开发用的都是swift语言&#xff0c;没有用过oc&#xff0c;本篇博客整理一下UIKIt中组件基于oc的使用&#xff0c;顺便把每个组件在秋招中遇到的问题整理一下。 UIView的使用 UIView继承链&#xff1a;NSObject->UIResponder->UIView UIView生命周期&…

大数据开源安全

在安全性方面从未有&#xff08;恕我直言&#xff09;已经足够了开源解决方案和布鲁斯已经撰写了有关这几个 时间在过去 &#xff0c;而且也没有必要再次改写参数。 现在&#xff0c;随着市场上“ NoSQL”和“大数据”开源趋势的发展&#xff0c;安全终于有了交集……如果我愿…

如何在一个页面添加多个不同的kindeditor编辑器

kindeditor官方下载地址&#xff1a;http://kindeditor.net/down.php &#xff08;入门必看&#xff09;kindeditor官方文档&#xff1a;http://kindeditor.net/doc.php &#xff08;入门必看&#xff09;Kindeditor编辑器初始化参数文档&#xff1a;http://kindeditor.net/doc…

JSONArray.fromObject不执行且不报错问题的解决

今天在写javaweb工程的时候需要向前台传json格式的数据&#xff0c;用到了json-lib-2.4-jdk15.jar等一系列包&#xff0c;然而却出现如下状况&#xff1a; CityBean是一个javaBean&#xff0c;我们看到&#xff0c;控制台只打印出了list的内容&#xff0c;而下面的两个却没能打…