多线程实现之实现callable接口

缺乏、安全感 2024-04-18 16:28 11阅读 0赞

Callable接口类似于Runnable，从名字就可以看出来了，但是Runnable不会返回结果，并且无法抛出返回结果的异常，而Callable功能更强大一些，被线程执行后，可以返回值，这个返回值可以被Future拿到，也就是说，Future可以拿到异步执行任务的返回值，下面来看一个简单的例子：

package juc;
    
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.FutureTask;
    
    public class TestCallable implements Callable<Integer> {
    
        @Override
        public Integer call() throws Exception {
            int sum=0;
            for (int i = 0; i <100 ; i++) {
                sum=sum+i;
    
                System.out.println(i);
    
            }
            return sum;
        }
    }
    
          class Tmain{
        public static void main(String[] args) {
            TestCallable rc = new TestCallable();
            //执行callable方法需要FutureTask实现类支持
            FutureTask<Integer> result = new FutureTask<>(rc);
            new Thread(result).start();
    
            try {
                Integer sum = result.get();
    
            System.out.println("-----------------------------------------");
                System.out.println(sum);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
    
        }
    }

来看一下输出结果

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTgzNDA5_size_16_color_FFFFFF_t_70][]

我么可以看出，sum的结果返回值是以后才执行，不光这个就输出语句的“----------”也是最后执行，这跟闭锁的机制有很大相似。

所以只要调用了get()方法后，之后的线程则会阻塞，等前面的线程执行完毕后再开启后面的线程。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTgzNDA5_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/5348e4ae649645d4aebd89908186eb4a.png