Callable 和Future

2024-06-24 08:48
文章标签 callable future

本文主要是介绍Callable 和Future,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在Java5之前,线程是没有返回值的,常常为了“有”返回值,破费周折,而且代码很不好写。或者干脆绕过这道坎,走别的路了。
现在Java终于有可返回值的任务(也可以叫做线程)了。 
可返回值的任务必须实现Callable接口,类似的,无返回值的任务必须Runnable接口。
执行Callable任务后,可以获取一个Future的对象,在该对象上调用get就可以获取到Callable任务返回的Object了。
下面是个很简单的例子:
import java.util.concurrent.*; 

/** 
* Java线程:有返回值的线程 

* @author Administrator 2009-11-5 0:41:50 
*/
 
public  class Test { 
         public  static  void main(String[] args)  throws ExecutionException, InterruptedException { 
                 //创建一个线程池 
                ExecutorService pool = Executors.newFixedThreadPool(2); 
                 //创建两个有返回值的任务 
                Callable c1 =  new MyCallable( "A"); 
                Callable c2 =  new MyCallable( "B"); 
                 //执行任务并获取Future对象 
                Future f1 = pool.submit(c1); 
                Future f2 = pool.submit(c2); 
                 //从Future对象上获取任务的返回值,并输出到控制台 
                System.out.println( ">>>"+f1.get().toString()); 
                System.out.println( ">>>"+f2.get().toString()); 
                 //关闭线程池 
                pool.shutdown(); 
        } 


class MyCallable  implements Callable{ 
         private String oid; 

        MyCallable(String oid) { 
                 this.oid = oid; 
        } 

        @Override 
         public Object call()  throws Exception { 
                 return oid+ "任务返回的内容"
        } 
}
>>>A任务返回的内容 
>>>B任务返回的内容 

Process finished with exit code 0

这篇关于Callable 和Future的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

【硬刚Java并发】JUC基础(五):实现 Callable 接口

本文是对《【硬刚大数据之学习路线篇】从零到大数据专家的学习指南(全面升级版)》的Java并发部分补充。 1 Callable 接口 Java 5.0 在 java.util.concurrent 提供了一个新的创建执行线程的方式:Callable 接口 Callable 接口类似于 Runnable,两者都是为那些其实例可能被另一个线程执行的类设计的。但是 Runnable 不会返回结果

Java并发编程:Callable和Future使用

在Java中,创建线程一般有两种方式,一种是继承Thread类,一种是实现Runnable接口。然而,这两种方式的缺点是在线程任务执行结束后,无法获取执行结果。我们一般只能采用共享变量或共享存储区以及线程通信的方式实现获得任务结果的目的。 不过,Java中,也提供了使用Callable和Future来实现获取任务结果的操作。Callable用来执行任务,产生结果,而Future用来获得结果。 C

std::future和std::promise详解(原理、应用、源码)

在编程实践中,我们常常需要使用异步调用。通过异步调用,我们可以将一些耗时、阻塞的任务交给其他线程来执行,从而保证当前线程的快速响应能力。还有一些场景可以通过将一个任务,分成多个部分然后将这部分交给多个线程来进行并发执行,从而完成任务的快速计算执行,提高应用性能。这里就需要用到异步调用的概念 异步调用,就是当前线程将一个任务交给另外一个线程来进行执行,当前线程会接着执行当前任务,不需要等待这个交付

Future 原理模拟

大家已经知道Future可以异步返回结果,但是其中的原理 却并不是所有人都懂  今天偶然看见了一段模拟原理的代码 就记录一下 首先大致介绍下其中的原理 : 在客户端请求的时候,直接返回客户端需要的数据(此数据不一定完整,只是简单的一点不耗时的操作),但是客户端并不一定马上使用所有的信息,此时就有了时间去完善客户需要的信息  大致原理如此 说到底就是一个简单的异步操作,下面贴上源码 并做简单的介绍

Java 通过Future来对任务进行取消

本节我们将通过Java中的Future实现对于提交的任务进行取消。ExecutorService.submit将返回一个Future来描述任务,Future拥有一个cancel方法,该方法带有一个boolean类型的参数mayInterruptIfRunning,表示取消操作是否成功(这个参数只是表示任务是否能够接收中断,而不是表示任务是否能检测并处理中断)。如果mayInterrup

【Python报错已解决】`TypeError: ‘numpy.ndarray‘ object is not callable`

引言: 在编程中,你是否遇到过尝试调用一个Numpy数组对象时出现了TypeError: 'numpy.ndarray' object is not callable的报错?这个问题通常是由于误将Numpy数组当成了一个函数来调用。接下来,我们将分析这个问题并提供解决方案。 一、问题描述: 1.1 报错示例: import numpy as np# 创建一个Numpy数组arra

论文笔记:Estimating future human trajectories from sparse time series data

sigspatial 2023 humob竞赛paper hiimryo816/humob2023-MOBB (github.com) 1 数据集分析 这里只分享了HuMob数据集1的内容 1.1 假日分析 对HuMob数据集#1地理数据的方差分析显示了非工作日的模式 在某些天的y坐标方差中有显著的峰值,这是非工作日的象征【x坐标有相似的模式】 ——>识别了任务1数据集中最有可能是

Java源码分析----Future

一般使用多线程操作的时候会使用Thread+Runnable进行处理,但是这种方式中,Runnable是没有返回值的,假设我们需要获取Runnable的返回值,可能需要如下特殊处理,伪代码如下 String returnValue1 = "";String returnValue2 = "";CountDownLatch cdl = ....new Thread(()->{// xxxx操

java多线程-使用Future获得多线程的返回值

我们在多线程中很多时候会需要获得线程的返回值,但是多线程又不像普通方法一样,可以直接获得返回值,那么我们应该怎么获得返回值呢?   一、使用Future获得Callable的返回值 import java.util.concurrent.Callable;import java.util.concurrent.ExecutorService;import java.util.conc

Callable Future Executor

一般通过继承Thread还有实现Runnable,都不可以有返回值,不可以声明检查异常。 Callable和Future,通过ExecutorService的submit方法执行Callable,并返回给Future,这里返回值只有一个,ExecutorService继承自Executor,通过使用Executor执行器来操作。 public class CallableAndFuture {