首页 / JAVA / java多线程（一）

java多线程（一）

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java多线程（一），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1778字，纯文字阅读大概需要3分钟。

内容图文

一、invokeAll

　　Executors支持通过invokeAll()一次批量提交多个callable。这个方法结果一个callable的集合，然后返回一个future的列表。

             1
            public
            static
            void main(String[] args) throws InterruptedException {
 2// 根据cpu是几核来开启几个线程 3         ExecutorService service = Executors.newWorkStealingPool();
 4         List<Callable<String>> callables = Arrays.asList(
 5                 () -> "task1",
 6                 () -> "task2",
 7                 () -> "task3",
 8                 () -> "task4",
 9                 () -> "task5");
1011        service.invokeAll(callables)
12                .stream()
13                 .map(future -> {
14try {
15return future.get();
16                    }
17catch (Exception e) {
18thrownew IllegalStateException(e);
19                    }
20                })
21                .forEach(System.out::println);
22     }

　　看一下Executors.newWorkStealingPool()调用源码为：

             1
            /**
             2
                 * Creates a work-stealing thread pool using all

             3
                 * {
            @link
             Runtime#availableProcessors available processors}

             4
                 * as its target parallelism level.

             5
                 * 
            @return
             the newly created thread pool

             6
                 * 
            @see
             #newWorkStealingPool(int)

             7
                 * 
            @since
             1.8

             8
            */
             9
            public
            static
             ExecutorService newWorkStealingPool() {

            10
            return
            new
             ForkJoinPool

            11
                        (Runtime.getRuntime().availableProcessors(),

            12
                         ForkJoinPool.defaultForkJoinWorkerThreadFactory,

            13
            null, true);
14     }

　　实际上Runtime.getRuntime().availableProcessors()获取CPU是集合，那么就开启几个线程来执行（通常默认为JVM可用的处理器个数）。

技术分享图片

　　看到还有另外一个ForkJoinPool.defaultForkJoinWorkerThreadFactory，源码是这样的：

             1
            /**
             2
              * Default ForkJoinWorkerThreadFactory implementation; creates a

             3
              * new ForkJoinWorkerThread.

             4
            */
             5
            static
            final
            class
             DefaultForkJoinWorkerThreadFactory

             6
            implements
             ForkJoinWorkerThreadFactory {

             7
            public
            final
             ForkJoinWorkerThread newThread(ForkJoinPool pool) {

             8
            return
            new
             ForkJoinWorkerThread(pool);

             9
                    }

            10     }

　　结合其他源码看起来ForkJoinPool：

　　1.初始化了一个线程池ForkJoinWorkerThread[parallelism..

　　2.初始化了一个任务队列submissionQueue[8]。

　--->每天进步一点！！！<---

原文：https://www.cnblogs.com/award/p/10087925.html

内容总结

以上是互联网集市为您收集整理的java多线程（一）全部内容，希望文章能够帮你解决java多线程（一）所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1264840.html

来源：【匿名】