zoukankan      html  css  js  c++  java
  • Thread Future模式

    多线程不管是extends Thread 还是 implements Runnable 都是要重写run 方法来实现,这两种方式子线程都没有返回值。

    如果要实现主线程对子线程的监听,让子线程有返回值,可以用implememts Callable<T> 方式:

    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    
    public class App6 {
        public static void main(String[] args) throws Exception {
            ExecutorService newCachedThreadPool = Executors.newCachedThreadPool();
            Future<String> submit = newCachedThreadPool.submit(new TaskCallable());
            String result = submit.get(); //获取返回值
            System.out.println(result);
        }
    
    }
    
    class TaskCallable implements Callable<String>{
        @Override
        public String call() throws Exception {
            System.out.println(Thread.currentThread().getName());
            return "Hello World";
        }
    }

     Future 模式的核心:去除了主函数的等待时间,并且使得原先需要等待的时间段可以去处理其他的业务逻辑。

     Future模式:对于多线程,如果线程A 需要去等待线程B的结果,那么线程A 没有必要去等待B,直到B 有结果,可以取一个未来的Future,等到B 有结果,再取真实的结果。

  • 相关阅读:
    django 使用form组件提交数据之form表单提交
    django from验证组件
    django中间件
    gin中http重复解析body数据失败
    go 常用工具链
    git 提交规范
    go简单实现heap
    Go优雅实现选传参数
    [已解决]protoc-gen-go: unable to determine Go import path for "xxx.proto"
    Go编译工具命令
  • 原文地址:https://www.cnblogs.com/pickKnow/p/11078908.html
Copyright © 2011-2022 走看看