用callable创建带返回值的线程方法，程序如下所示：

import java.util.concurrent.*;

class ThreadExc03 implements Callable<String>{
        private int tick = 100;
        public String call() {//又返回值的执行体
                for ( ;tick>0 ; )  {
                        System.out.println(Thread.currentThread().getName()+"正在出售第"+tick--+"张票！");
                } return "票已告罄！";//线程执行完毕，返回String
        }
        public static void main(String[] args) {
                ThreadExc03 te3 = new ThreadExc03();
                FutureTask ft = new FutureTask<String>(te3);//用FutureTask进行包装。
                Thread t1 = new Thread(ft,"VIP窗口");//将FutureTask的对象作为线程的Target
                //Thread t2 = new Thread(ft,"普通窗口");//新开一个线程，但是没有结果，
                //Thread t3 = new Thread(ft,"应急窗口");//新开一个线程，但是没有结果，
                t1.start();
                //t2.start();
                //t3.start();
                try{
                        System.out.println(ft.get());//用FutureTask获取返回值；
                }catch(Exception e){
                  System.out.println("程序异常！");
                }
        }
}



输出结果为：

VIP窗口正在出售第100张票！
VIP窗口正在出售第99张票！
VIP窗口正在出售第98张票！
VIP窗口正在出售第97张票！
VIP窗口正在出售第96张票！
VIP窗口正在出售第95张票！
VIP窗口正在出售第94张票！
VIP窗口正在出售第93张票！
……
……
VIP窗口正在出售第8张票！
VIP窗口正在出售第7张票！
VIP窗口正在出售第6张票！
VIP窗口正在出售第5张票！
VIP窗口正在出售第4张票！
VIP窗口正在出售第3张票！
VIP窗口正在出售第2张票！
VIP窗口正在出售第1张票！
票已告罄！


问题是虽然这个方法可以建立多条线程来共享一个target,但是通过运行结果可以发现，处理Call()的线程只有一个输出，请问如何验证建立多条线程的时候，其他的线程有或者没有被执行？callable接口是否只有一个线程控制数据或者多条线程共享数据？

implements Callable了可以创建线程吗

楼主你好，很高兴和你交流。

1. import java.util.concurrent.*;
   
2. 
   
3. class Test001
   
4. {
   
5. public static void main(String[] args) throws Exception //为了方便测试，我就直接抛出异常了
   
6. {
   
7. TicketWindow tw = new TicketWindow(); //Callable接口的实现类
   
8. 
   
9. ExecutorService exec = Executors.newCachedThreadPool(); //线程池
   
10. /*
    
11. //第一种方式
    
12. Future<String> f1 = exec.submit(tw); //首先是用Future类实现的，使用Future类就必须使用ExecutorService.submit()方法
    
13. Future<String> f2 = exec.submit(tw);
    
14. 
    
15. System.out.println("f1: " + f1.get());
    
16. System.out.println("f2: " + f2.get());
    
17. */
    
18. 
    
19. /*
    
20. //第二种方式
    
21. FutureTask<String> ft1 = new FutureTask<String>(tw); //使用了FutureTask包装。
    
22. FutureTask<String> ft2 = new FutureTask<String>(tw);
    
23. 
    
24. exec.execute(ft1); //使用的是Executor.execute()方法
    
25. exec.execute(ft2);
    
26. 
    
27. System.out.println("ft1: " + ft1.get());
    
28. System.out.println("ft2: " + ft2.get());
    
29. */
    
30. 
    
31. exec.shutdown();
    
32. 
    
33. 
    
34. FutureTask<String> ft1 = new FutureTask<String>(tw); //第三种方式
    
35. FutureTask<String> ft2 = new FutureTask<String>(tw);
    
36. 
    
37. new Thread(ft1, "VIP").start();
    
38. new Thread(ft2, "VIP2").start();
    
39. 
    
40. System.out.println("ft1: " + ft1.get());
    
41. System.out.println("ft2: " + ft2.get());
    
42. 
    
43. }
    
44. }
    
45. 
    
46. class TicketWindow implements Callable<String>
    
47. {
    
48. private int ticket = 20;
    
49. public String call() {
    
50. System.out.println(Thread.currentThread().getName() + "启动了。。。");
    
51. for(;ticket>0;) {
    
52. System.out.println(Thread.currentThread().getName()+"---售出了第:"+ticket-- + "票");
    
53. }
    
54. 
    
55. return "已经售完。";
    
56. }
    
57. }
    

复制代码

具体解释我写在了注释中。

执行效果如下：

希望对你有所帮助。

875588381 发表于 2014-5-18 14:22
楼主你好，很高兴和你交流。
具体解释我写在了注释中。

原来用的是线程池，我也试一下，感谢不吝赐教…

姜蕾蕾 发表于 2014-5-20 11:12
原来用的是线程池，我也试一下，感谢不吝赐教…

不客气，大家互相帮助。:)

不明觉厉