利用多线程进行多核计算

  1、利用多线程进行多核计算,利用多核计算提升计算性能。

  2、通过CountDownLatch countDownLatch = new CountDownLatch(threadSize);来将多个计算线程结果返回给主线程进行合并。

  3、通过单例来生产固定大小线程池

 private static Logger logger = LoggerFactory.getLogger(ThreadTool.class);
    private static ThreadTool threadTool;
    private ExecutorService executorService;
        
    private ThreadTool(){
        NamedThreadFactory threadFactory = new NamedThreadFactory("Gbdt-Thread-", true);
        RejectedExecutionHandler handler = new RejectedExecutionHandler() {
            private int i = 1;
            @Override
            public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                if (i++ % 7 == 0) {
                    i = 1;
                    logger.warn("[Gbdt-23002]Task:{} has been reject for ThreadPool exhausted!" +
                                    " pool:{}, active:{}, queue:{}, taskcnt: {}",
                            new Object[]{
                                    r,
                                    executor.getPoolSize(),
                                    executor.getActiveCount(),
                                    executor.getQueue().size(),
                                    executor.getTaskCount()
                            });
                }
       throw new RejectedExecutionException("[Gbdt-23003]Gbdt thread pool of provider has bean exhausted");
            }
        };
                
        executorService = new ThreadPoolExecutor(20, 500,
                60, TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<Runnable>(), threadFactory, handler);
    
    }
    
            public static ThreadTool getInstance(){
        synchronized (ThreadTool.class) {
            if (threadTool == null) {                 //Double Checked
                threadTool = new ThreadTool();
            }
        }
        return threadTool;
    }
    
    public ExecutorService getExecutorService(){
        return executorService;
    }

  4、获得线程池并将任务线程添加到线程中。

ExecutorService executorService= threadTool.getExecutorService(); executorService.execute(thread);

  5、线程将执行完后将

 // 倒数器减1
        countDownLatch.countDown();

  6、countDownLatch设置等待时间countDownLatch减到0或超时则返回。

try

                {
                    // 阻塞当前线程,直到倒数计数器倒数到0
                    countDownLatch.await(200, TimeUnit.MILLISECONDS);
                }
                catch (InterruptedException e)
                {
                    log.error("线程计算异常:"+e.getMessage(),e);
                }

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Java Edge

Java并发编程实战系列8之线程池的使用

ThreadPoolExecutor UML图: ? image ? image ? 8.1 在任务和执行策略之间隐形耦合 避免Thread starvati...

3639
来自专栏扎心了老铁

springboot scheduled并发配置

本文介绍如何使用springboot的sheduled实现任务的定时调度,并将调度的任务实现为并发的方式。 1、定时调度配置scheduled 1)注册定时任务...

8057
来自专栏码匠的流水账

聊聊rocketmq的RequestTask

org/apache/rocketmq/remoting/netty/RequestTask.java

1012
来自专栏后台及大数据开发

springBoot系列教程04:mybatis及druid数据源的集成及查询缓存的使用

首先说下查询缓存:查询缓存就是相同的数据库查询请求在设定的时间间隔内仅查询一次数据库并保存到redis中,后续的请求只要在时间间隔内都直接从redis中获取,不...

771
来自专栏Java学习网

Spring MVC学习教程之流程表单提交,3步实现这个功能

本文中将用Spring实现流程表单的提交功能,具体功能是使用web表单来添加一个新员工到员工名单列表中。 ? 网络配图 第1步:准备所需的类 添加 addEmp...

3725
来自专栏一个会写诗的程序员的博客

sqlSessionFactoryBean.setMapperLocations 通配符 在配置代码中怎样使用

sqlSessionFactoryBean.setMapperLocations 通配符 在配置代码中怎样使用

964
来自专栏林冠宏的技术文章

通俗易懂,各常用线程池的执行 流程图

corePoolSize,maximumPoolSize,workQueue之间关系。

1433
来自专栏林冠宏的技术文章

通俗易懂,各常用线程池的执行 流程图

作者:林冠宏 / 指尖下的幽灵 腾讯云+社区:https://cloud.tencent.com/developer/user/1148436/activ...

2269
来自专栏Netkiller

String boot with Apache kafka 完整的发布订阅例子

本文节选自电子书《Netkiller Java 手札》地址 http://www.netkiller.cn/ 5.21.7. 完整的发布订阅实例 上面的例子仅仅...

3066
来自专栏Netkiller

Spring boot with PostgreSQL

本文节选自《Netkiller Java 手札》 作者 netkiller 他的网站 http://www.netkiller.cn 5.15. Spring ...

2715

扫码关注云+社区