========转载=========
在Java 线程中返回值的用法
博客分类: Java
Javathread
有时在执行线程中需要在线程中返回一个值;常规中我们会用Runnable接口和Thread类设置一个变量;在run()中改变变量的值,再用一个get方法取得该值,但是run何时完成是未知的;我们需要一定的机制来保证。
在在Java se5有个Callable接口;我们可以用该接口来完成该功能;
代码如:
Java代码
package com.threads.test;
import java.util.concurrent.Callable;
public class CallableThread implements Callable<String> {
private String str;
private int count=10;
public CallableThread(String str){
this.str=str;
}
//需要实现Callable的Call方法
public String call() throws Exception {
for(int i=0;i<this.count;i++){
System.out.println(this.str+" "+i);
}
return this.str;
}
}
在call方法中执行在run()方法中一样的任务,不同的是call()有返回值。
call的返回类型应该和Callable<T>的泛型类型一致。
测试代码如下:
Java代码
package com.threads.test;
import java.util.ArrayList;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class CallableTest {
public static void main(String[] args) {
ExecutorService exs=Executors.newCachedThreadPool();
ArrayList<Future<String>> al=new ArrayList<Future<String>>();
for(int i=0;i<10;i++){
al.add(exs.submit(new CallableThread("String "+i)));
}
for(Future<String> fs:al){
try {
System.out.println(fs.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
}
submit()方法返回一个Futrue对象,可以通过调用该对象的get方法取得返回值。
通过该方法就能很好的处理线程中返回值的问题。
如果希望调用的线程不但能执行指定的任务,还想有返回值,这时我们就可以使用Callable与Future接口来实现。至于它的方法可以去查找相关API。下面来看一个例子:
package wyf.jc;
import java.util.concurrent.*;
//实现了Callable接口的任务类
class MyCallableImpl implements Callable{
String taskName;
public MyCallableImpl(String taskName){
this.taskName=taskName;
}
//存放任务代码的run
public Object call(){
System.out.println(taskName+"任务成功执行!");
return "恭喜你,任务成功执行,我是返回消息";
}
}
public class sample17_6 {
/**
* @param args
*/
public static void main(String[] args) {
//创建线程
ExecutorService threadPool=Executors.newSingleThreadExecutor();
//调用线程池的submit方法执行任务
Future future=threadPool.submit(new MyCallableImpl("taskA"));
try{
//调用阻塞方法get获取任务的返回值
System.out.println(future.get());
}catch(Exception ex){
ex.printStackTrace();
}
threadPool.shutdown();
}
}
运行结果如下:
taskA任务成功执行!
恭喜你,任务成功执行,我是返回消息
分享到:
相关推荐
大家都知道实现多线程的2种方式,今天来讲讲Future实现具有返回值的线程。应用场景:前端调用时无需等待线程结束返回,线程结束后需进行其它操作如更新状态、通知kafuka等。
主要介绍了python使用threading获取线程函数返回值的实现方法,需要的朋友可以参考下
大家都知道Runnable和Callable接口都可以作为其他线程执行的任务,但是Runnable接口的run方法没有返回值,而Callable接口的call方法有返回值,那么Callable接口是如何做到的呢?在此我给出一个Demo,看看通过...
vc中获取一个线程的状态及返回值,VS2012工程,通过点击界面上按钮,启动一个判断线程,然后再这个判断线程启动一个工作线程,在判断线程里判断工作线程的工作状态
易语言线程返回数据的方法源码,线程返回数据的方法,线程
NULL 博文链接:https://icgemu.iteye.com/blog/467848
主要介绍了C++多线程获取返回值方法详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
Java线程:新特征-有返回值的线程 Java线程:新特征-锁(上) Java线程:新特征-锁(下) Java线程:新特征-信号量 Java线程:新特征-阻塞队列 Java线程:新特征-阻塞栈 Java线程:新特征-条件变量 Java线程:新特征...
Java线程:新特征-有返回值的线程 Java线程:新特征-锁(上) Java线程:新特征-锁(下) Java线程:新特征-信号量 Java线程:新特征-阻塞队列 Java线程:新特征-阻塞栈 Java线程:新特征-条件变量 Java线程...
最近有个需求,用多线程比较合适,但是我需要每个线程的返回值,这就需要我在threading.Thread的基础上进行封装 import threading class MyThread(threading.Thread): def __init__(self,func,args=()): super...
在许多时候,我们会有这样的需求——即我们想要得到线程返回的值。 但是在C++11 多线程中我们注意到,std::thread对象会忽略顶层函数的返回值。 那问题来了,我们要怎么获得线程的返回值呢? 我们通过一个例子来说明...
这篇文章主要介绍了Python多线程获取返回值代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 在使用多线程的时候难免想要获取其操作完的返回值进行其他...
(1)掌握Windows系统提供的线程创建与撤销系统调用 (2)掌握Windows系统环境下线程的创建与撤销方法 2 实验准备知识 (1)线程创建 CreateThread()完成线程的创建。它在调用进程的地址空间上创建一个线程,执行...
java线程的run()没有返回值怎么办?本文给出了java线程的run()返回值为空的解决办法,感兴趣的小伙伴们可以参考一下
多线程机制 1 1、 Runnable接口与Thread类 1 2、 两个创建线程方法的比较 3 3、 几个常用的改变线程状态的方法 3 ...9、 Callable 有返回值的线程 20 10、 Callable结合FutureTask的多线程使用(免打扰模式) 24
Java线程:新特征-有返回值的线程 Java线程:新特征-锁(上) Java线程:新特征-锁(下) Java线程:新特征-信号量 Java线程:新特征-阻塞队列 Java线程:新特征-阻塞栈 Java线程:新特征-条件变量 Java线程:新特征...