利用多线程进行多核计算

  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 条评论
登录 后参与评论

相关文章

来自专栏IT笔记

SpringBoot开发案例之多任务并行+线程池处理

前几篇文章着重介绍了后端服务数据库和多线程并行处理优化,并示例了改造前后的伪代码逻辑。当然了,优化是无止境的,前人栽树后人乘凉。作为我们开发者来说,既然站在了巨...

1.3K19
来自专栏古时的风筝

Java 中的几种线程池,你之前用对了吗

虽然大家应该都已经很清楚了,但还是说一下。其实归根结底最主要的一个原因就是为了提高性能。

630
来自专栏Android-薛之涛

Android-Threadpool

     关于线程我不想再说什么,感兴趣的同学可以看我之前写过的一篇文章:Android-多线程,这里对线程有一个比较详细的解释。

541
来自专栏码匠的流水账

SynchronousQueue使用实例

SynchronousQueue,实际上它不是一个真正的队列,因为它不会为队列中元素维护存储空间。与其他队列不同的是,它维护一组线程,这些线程在等待着把元素加入...

391
来自专栏架构说

线程池的作用

问题: nginx 写的线程池太过抽象根本理解不了 例如 pthread_create()函数创建了线程 线程就开始提供服务了(还需要提供别人使用),回收更解...

34813
来自专栏码洞

如何解决Java线程池队列过饱问题

Java的Executors框架提供的定长线程池内部默认使用LinkedBlockingQueue作为任务的容器,这个队列是没有限定大小的,可以无限向里面sub...

481
来自专栏空帆船w

Android Handler 消息处理机制

日常开发中,一般不会在子线程中直接进行 UI 操作,大部分采取的办法是创建 Message 对象,然后借助 Handler 发送出去,再在 Handler 的 ...

663
来自专栏IT笔记

ThreadPoolExecutor-线程池开发的使用

1:必须明白为什么要使用线程池:(这点很重要) ?   a:手上项目所需,因为项目主要的目的是实现多线程的数据推送;需要创建多线程的话,那就要处理好线程安全...

3667
来自专栏移动开发面面观

Android线程池的详细说明(一)

1332
来自专栏木木玲

Netty in action ——— 事件循环 和 线程模式

1553

扫码关注云+社区