JAVA多线程处理for循环数据详细讲解

更新时间：2023年07月28日 11:35:59 作者：二拾三

这篇文章主要给大家介绍了关于JAVA多线程处理for循环数据的相关资料,我们在代码中经常需要使用for循环这个操作来达到目的,而当for循环的次数过多时我们会发现执行效率会变的很低,整体耗时非常多,需要的朋友可以参考下

1.对for循环内数据启用多线程执行，主线程与子线程无先后顺序

    public static void main(String[] args) throws InterruptedException {
        for (int i = 0; i < 5; i++) {
            ThreadUtil.execAsync(() -> {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("线程" + Thread.currentThread().getName() + "执行完");
            });
            System.out.println("第" + i + "个线程");
        }
        System.out.println("完成");
    }

执行结果：

2.对for循环内数据启用多线程执行，主线程在所有子线程执行完成之后执行

    public static void main(String[] args) throws InterruptedException {
        //初始化线程数量
        CountDownLatch countDownLatch = ThreadUtil.newCountDownLatch(5);
        for (int i = 0; i < 5; i++) {
            ThreadUtil.execute(() -> {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("线程" + Thread.currentThread().getName() + "执行完");
                //调用线程计数器-1
                countDownLatch.countDown();
            });
            System.out.println("第" + i + "个线程");
        }
        //唤醒主线程
        countDownLatch.await();
        System.out.println("完成");
    }

执行结果：

3.对for循环内数据启用多线程执行，主线程在所有子线程执行完成之后执行

 public static void main(String[] args) throws InterruptedException {
        // 线程个数
        int N = 10;
        // 实例化一个倒计数器，N指定计数个数
        CountDownLatch countDownLatch = new CountDownLatch(N);
        for (int i = 0; i < N; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread.sleep(5000);
                        System.out.println("子线程" + Thread.currentThread().getName() + "休眠结束");
                    } catch (Exception e) {
                        e.printStackTrace();
                    } finally {
                    	// 计数减一
                        countDownLatch.countDown(); 
                    }
                }
            }).start();
        }
        // 阻塞，等待当计数减到0时，执行后面的代码
        countDownLatch.await();
        System.out.println("结束");
    }

执行结果：

4. JAVA多线程10个线程处理1000个数据

    public static void main(String[] args) throws Exception {
        List<Integer> idList = new ArrayList<>();
        for (int i = 1; i <= 1000; i++) {
            idList.add(i);
        }
        int threadNum = 10;
        ExecutorService executorService = Executors.newFixedThreadPool(threadNum);
        CountDownLatch countDownLatch = new CountDownLatch(threadNum);
        int perSize = idList.size() / threadNum;
        // 定义接受数据集合  多线程情况下，使用线程安全集合
        List<Integer> resultList = Collections.synchronizedList(new ArrayList());
        for (int i = 0; i < threadNum; i++) {
            MultiThread thread = new MultiThread();
            thread.setIdList(idList.subList(i * perSize, (i + 1) * perSize));
            thread.setCountDownLatch(countDownLatch);
            thread.setResultList(resultList);
            executorService.submit(thread);
        }
        countDownLatch.await();
        executorService.shutdown();
        // 查看结果
        System.out.println(resultList.size());
        System.out.println(resultList.stream().sorted().collect(Collectors.toList()));
    }
}
class MultiThread extends Thread {
    private List<Integer> idList;
    private CountDownLatch countDownLatch;
    private List<Integer> result;
    public void setResultList(List<Integer> result) {
        this.result = result;
    }
    public void setIdList(List<Integer> idList) {
        this.idList = idList;
    }
    public void setCountDownLatch(CountDownLatch countDownLatch) {
        this.countDownLatch = countDownLatch;
    }
    @Override
    public void run() {
        try {
            // 数据处理
            for (Integer integer : idList) {
                if (integer % 2 == 0) {
                    result.add(integer);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (countDownLatch != null) {
                countDownLatch.countDown();
            }
        }
    }

执行结果：

总结

到此这篇关于JAVA多线程处理for循环数据的文章就介绍到这了,更多相关JAVA处理for循环数据内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

批量将现有Jar包上传到Maven私服
今天小编就为大家分享一篇关于批量将现有Jar包上传到Maven私服，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
2018-12-12
java关于并发模型中的两种锁知识点详解
在本篇文章了小编给大家整理的是一篇关于java关于并发模型中的两种锁知识点详解内容，有兴趣的朋友们可以学习下。
2021-04-04
Java中的IO读写原理详解
这篇文章主要介绍了Java中的IO读写原理,IO是指输入和输出操作的技术,它提供了一组用于读取和写入数据的类,以及用于处理字符和字节数据的接口,这些类和接口可以用于读取和写入文件、网络流、内存缓冲区等各种数据源和目标,需要的朋友可以参考下
2023-08-08
Elasticsearch查询之Match Query示例详解
这篇文章主要为大家介绍了Elasticsearch查询之Match查询示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-04-04
SpringBoot集成antlr实现词法和语法分析
Antlr4 是一款强大的语法生成器工具,可用于读取、处理、执行和翻译结构化的文本或二进制文件,基本上是当前 Java 语言中使用最为广泛的语法生成器工具,本文给大家介绍了SpringBoot集成antlr实现词法和语法分析,需要的朋友可以参考下
2024-06-06
Spring 循环依赖之AOP实现详情
这篇文章主要介绍了Spring 循环依赖之AOP实现详情，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的盆友可以参考一下
2022-07-07
Java使用synchronized修饰方法来同步线程的实例演示
synchronized下的方法控制多线程程序中的线程同步非常方便,这里就来看一下Java使用synchronized修饰方法来同步线程的实例演示,需要的朋友可以参考下
2016-06-06
阿里nacos+springboot+dubbo2.7.3统一处理异常的两种方式
本文主要介绍了阿里nacos+springboot+dubbo2.7.3统一处理异常的两种方式，文中根据实例编码详细介绍的十分详尽，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-03-03
Java生成唯一ID的三种方法总结
单机环境下,可以使用AtomicLong来生成唯一ID；而在需要非纯数字形式的场景中,可以通过UUID结合哈希函数如MD5或SHA-1转换成数字,但需注意哈希碰撞的低概率风险；对于分布式系统,模拟Snowflake算法是一种复杂但有效的方法,每种方法都有其适用场景和潜在问题
2024-09-09
Java中的final关键字深入理解
这篇文章主要介绍了Java中的final关键字深入理解的相关资料,需要的朋友可以参考下
2017-02-02

JAVA多线程处理for循环数据详细讲解

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具