最新文章列表

Future和Callable的使用

ExecutorService中的submit(Callable)方法可以执行Callable任务,并且使用Future接口中的get()方法获取返回值。示例如下: public class HomeRegNumCallable implements Callable<Map<String, Object>>{ private String newDate; priv ...
taiwei.peng 评论(0) 有299人浏览 2020-05-04 22:16

callback,future使用

import java.util.concurrent.*; public class FutureTaskTest { public static void main(String[] args) { // 线程1 Callable<String> tempCall1 = new Callable<String> ...
落叶换新叶 评论(0) 有732人浏览 2019-09-26 16:35

关于 Future 类 boolean cancel(boolean mayInterruptIfRunning) 的疑问

boolean cancel(boolean mayInterruptIfRunning) 方法描述: /**      * Attempts to cancel execution of this task.  This attempt will      * fail if the task has already completed, has already been cancelled, ...
一剪梅 评论(0) 有2361人浏览 2019-01-10 21:05

Java并发编程:Callable、Future和FutureTask

在前面的文章中我们讲述了创建线程的2种方式,一种是直接继承Thread,另外一种就是实现Runnable接口。   这2种方式都有一个缺陷就是:在执行完任务之后无法获取执行结果。   如果需要获取执行结果,就必须通过共享变量或者使用线程通信的方式来达到效果,这样使用起来就比较麻烦。   而自从Java 1.5开始,就提供了Callable和Future,通过它们可以在任务执行完毕之后得到任务 ...
yuwenlin2008 评论(0) 有474人浏览 2018-04-01 22:07

Callable 与 Future

  import java.util.ArrayList; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import ja ...
knight_black_bob 评论(0) 有538人浏览 2018-01-25 17:51

获取子线程返回结果(Future的使用)

当我们在主线程中起一个线程去处理任务,通常这个处理过程是异步的,主线程直接响应结果。 但如果这个过程是同步的,即主线程等待子线程的响应后,再去响应,应该怎么做? 执行任务的类,类似实现Runnable。 要设置一个泛型,即任务的返回结果 public class MyCallable implements Callable<Integer> { //返回一个随机数 @Ove ...
冰封之月 评论(0) 有3189人浏览 2017-11-13 09:38

JDK中ExecutorService,Callable,Future对线程的支持

1、代码背景:     假如有Thread1、Thread2、Thread3、Thread4四条线程分别统计C、D、E、F四个盘的大小,所有线程都统计完毕交给Thread5线程去做汇总,应当如何实现? 2、代码:     统计“盘子”大小的代码,此处实现jdk中的Callable接口, package com.wang.test.concurrent; import java.uti ...
莫欺少年穷Java 评论(0) 有927人浏览 2017-09-20 10:12

quartz执行卡死--强制中断线程

在quartz中经常会碰到由于网络问题或者一些其他不稳定因素导致的线程卡死问题,这往往会导致数据处理的延时。而有时候一时无法定位到卡死的原因,为了降低系统风险,我们就会希望有一个超时机制,当执行超时时强制中断该操作。下面就举个例子,ftp协议不稳定,当连接ftp上传下载数据时有时候会遇到不可知的因素会导致卡死,比如说主动被动切换,服务器连接数满等等,现在我们使用java提供的动态代理以及Futu ...
征途2010 评论(0) 有3267人浏览 2017-03-08 11:48

Java之 java.util.concurrent 包之ExecutorService之submit () 之 Future

一、如何使用 ExecutorService.submit() ? submit() 可以接受 Callable 或 Runnable 对象。 返回值是 Future 对象(调用 Future 对象的 get() 方法会导致主线程阻塞)。 二、程序 import java.util.concurrent.Callable; import java.util.concurren ...
Lixh1986 评论(0) 有3834人浏览 2017-03-04 21:27

Java之多线程之Callable与Future

Java之多线程之Callable与Future 从 Java 5 开始出现了 java.util.concurrent 包,该包在多线程环境中应用广泛。 一、 java.util.concurrent.Callable Callable 接口 与 Runnable 接口类似,不同的是它们的唯一的 run 方法: 1、Callable 有返回值,Runnable 没有。    Callabl ...
Lixh1986 评论(0) 有5838人浏览 2017-01-08 22:48

Java并发编程之异步Future机制的原理和实现

Java并发编程之异步Future机制的原理和实现           项目中经常有些任务需要异步(提交到线程池中)去执行,而主线程往往需要知道异步执行产生的结果,这时我们要怎么做呢?用runnable是无法实现的,我们需要用callable看下面的代码: import java.util.concurrent.Callable; import java.util.concurrent. ...
莫名的拉风 评论(4) 有38728人浏览 2016-08-23 17:10

ExecutorCompletionService

当我们通过Executor提交一组并发执行的任务,并且希望在每一个任务完成后能立即得到结果,有两种方式可以采取:   方式一: 通过一个list来保存一组future,然后在循环中轮训这组future,直到每个future都已完成。如果我们不希望出现因为排在前面的任务阻塞导致后面先完成的任务的结果没有及时获取的情况,那么在调用get方式时,需要将超时时间设置为0  Java代码   ...
wbj0110 评论(0) 有540人浏览 2016-06-22 12:53

Callable与Future的介绍

        Callable与 Future 两功能是Java在后续版本中为了适应多并法才加入的,Callable是类似于Runnable的接口,实现Callable接口的类和实现Runnable的类都是可 ...
bijian1013 评论(0) 有1376人浏览 2016-03-07 19:45

java异步计算场景应用

最近项目中遇到一个业务场景: 将当期数据库中的表迁移到另外一个数据库中,为满足迁移效率需要进行并发数据迁移。对每一数据表可以启动不同的线程同时迁移数据。迁移完成后,同步更新对应该迁移任务的状态字段。 最先想到的是使用java中并发工具类:同步屏障CyclicBarrier。 CyclicBarrier的字面意思是可循环使用(Cyclic)的屏障(Barrier)。它要做的事情是,让一组线程到达一个屏 ...
richard_lee 评论(3) 有2911人浏览 2016-02-14 09:06

java并发编程-3

之前做的并发1、2都是做的Runnable,虽然能够实现线程之间的互斥、通信,但是不能实现两个线程之间的信息共享,必须有这样一个需求:有一个service ...
suichangkele 评论(0) 有569人浏览 2015-12-17 10:48

Callable<V>、Future<V>详解 | Executor框架

  一:关于 Callable<V>的源码 package java.util.concurrent; public interface Callable<V> { /** * Computes a result, or throws an exception if unable to do so. * * @r ...
周凡杨 评论(0) 有4295人浏览 2015-09-29 18:12

CompletionService、Future

一.CompletionService接口提供了可以操作异步任务的功能,其唯一实现的API为ExecutorCompletionService。此API只是可以获取异步任务执行的结果,它不是ExecutorService。 其有5个核心方法: Future<V> poll():同步操作,获取并移除第一已经完成的任务,否则返回null。 Future<V> ...
IXHONG 评论(0) 有829人浏览 2015-07-23 11:16

java future模式举例

java future模式举例                                                                                                         ——我一直不太信任自己的记忆力,所以我把它们都写下来        Future模式在java中简单使用直接模拟场景,然后看实例,一直以来喜欢这种直接的 ...
云上太阳 评论(0) 有716人浏览 2015-06-19 16:08

FutureTask的使用示例

今天看书,有关于 FutureTask 的介绍,感觉还蛮有意思的,可以用它来做一些比较花时间的事情。下面打个通俗的比方来说明一下它的用处: 比如,早上一大早的去公交站台等公交,但那该死的公交20分钟才一班。如果一直死等公交,那么这20分钟无疑就被浪费了。我们可以利用这20分钟,去买个韭菜饼,再买一盒豆浆,然后一边吃一边等。这样就明显提高了时间的利用率。   下面给出一个段简单的代码来说明一下 ...
Rainbow702 评论(0) 有4044人浏览 2015-04-26 20:05

最近博客热门TAG

Java(141747) C(73651) C++(68608) SQL(64571) C#(59609) XML(59133) HTML(59043) JavaScript(54918) .net(54785) Web(54513) 工作(54116) Linux(50906) Oracle(49876) 应用服务器(43288) Spring(40812) 编程(39454) Windows(39381) JSP(37542) MySQL(37268) 数据结构(36423)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics