在Java 线程中返回值的用法

时间：2022-01-27 21:49:09

http://icgemu.iteye.com/blog/467848

有时在执行线程中需要在线程中返回一个值；常规中我们会用Runnable接口和Thread类设置一个变量；在run()中改变变量的值，再用一个get方法取得该值，但是run何时完成是未知的；我们需要一定的机制来保证。

在在Java se5有个Callable接口；我们可以用该接口来完成该功能；

代码如：

  1. package com.threads.test;
  2. import java.util.concurrent.Callable;
  3. public class CallableThread implements Callable<String> {
  4. private String str;
  5. private int count=10;
  6. public CallableThread(String str){
  7. this.str=str;
  8. }
  9. //需要实现Callable的Call方法
  10. public String call() throws Exception {
  11. for(int i=0;i<this.count;i++){
  12. System.out.println(this.str+" "+i);
  13. }
  14. return this.str;
  15. }
  16. }

在call方法中执行在run（）方法中一样的任务，不同的是call（）有返回值。 
call的返回类型应该和Callable<T>的泛型类型一致。 
测试代码如下：

  1. package com.threads.test;
  2. import java.util.ArrayList;
  3. import java.util.concurrent.ExecutionException;
  4. import java.util.concurrent.ExecutorService;
  5. import java.util.concurrent.Executors;
  6. import java.util.concurrent.Future;
  7. public class CallableTest {
  8. public static void main(String[] args) {
  9. ExecutorService exs=Executors.newCachedThreadPool();
  10. ArrayList<Future<String>> al=new ArrayList<Future<String>>();
  11. for(int i=0;i<10;i++){
  12. al.add(exs.submit(new CallableThread("String "+i)));
  13. }
  14. for(Future<String> fs:al){
  15. try {
  16. System.out.println(fs.get());
  17. } catch (InterruptedException e) {
  18. e.printStackTrace();
  19. } catch (ExecutionException e) {
  20. e.printStackTrace();
  21. }
  22. }
  23. }
  24. }

submit()方法返回一个Futrue对象，可以通过调用该对象的get方法取得返回值。 
通过该方法就能很好的处理线程中返回值的问题。

相关文章