Java多线程消费一个list

付威

发布于 2020-01-21 17:55:46

1.9K0

发布于 2020-01-21 17:55:46

文章被收录于专栏：老付的网络博客老付的网络博客

在项目中，常常会需要处理一个list数据列表，使用多线程来加速数据的处理。

需要保证两点：

能灵活控制线程的数量
能够同步的完成一批list的数据

可以使用信号量和线程池，具体实现代码如下：

public static <T> void startWithMultiThread(List<T> list, int nThread, Consumer<T> func) {
        if (CollectionUtils.isEmpty(list)) {
            return;
        }
        if (nThread <= 0) {
            return;
        }
        if (func == null) {
            return;
        }
        if (CollectionUtils.isEmpty(list)) {
            return;
        }
        Semaphore semaphore = new Semaphore(nThread);//定义几个许可
        ExecutorService executorService = Executors.newFixedThreadPool(nThread);//创建一个固定的线程池
        for (T obj : list) {
            try {
                semaphore.acquire();
                executorService.execute(() -> {
                    try {
                        func.accept(obj);
                        semaphore.release();
                    } catch (Exception ex) {
                
                    }
                });
            } catch (InterruptedException e) {

            }
        }
        executorService.shutdown();
    }

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2019-03-23 ，如有侵权请联系 cloudcommunity@tencent.com 删除

list