一点一点看JDK源码（五）java.util.ArrayList 后篇之Spliterator多线程遍历

一点一点看JDK源码（五）java.util.ArrayList 后篇之Spliterator多线程遍历

liuyuhang原创，未经允许禁止转载

本文举例使用的是JDK8的API

目录：一点一点看JDK源码（〇）

Spliterator为jdk1.8新增接口，由ArrayList.spliterator();获得其返回值对象Spliterator。

该对象可以使用trySplit进行迭代器拆分，每次拆分后的迭代器接近上一次的二分之一。

这是官方对于大数据量数组多线程遍历加工的一种趋势性指引。

首先需要定义一个线程，

然后需要将拆分后的迭代器传入该线程。

执行start（）方法让实现的run（）方法进入就绪状态等待调用

自定义线程代码如下：

 package com.FM.ArrayListStudy;

 import java.util.Spliterator;

 import java.util.function.Consumer;

 /**

  * 内部类,线程调用

  */

 public class MyThread4Spliterator<T> extends Thread {

     // 寄存变量

     private Spliterator<T> list;

     // 构造 - 传递参数

     public MyThread4Spliterator(Spliterator<T> list) {

         setList(list);

     }

     // 线程调用run

     @Override

     public void run() {

         Spliterator<T> list2 = getList();

         list2.forEachRemaining(new Consumer<T>() {

             @Override

             public void accept(T t) {

                 System.out.println(Thread.currentThread().getName()+" === "+t);

             }

         });

     }

     public Spliterator<T> getList() {

         return list;

     }

     public void setList(Spliterator<T> list) {

         this.list = list;

     }

 }

定义并拆分迭代器代码如下，需要注意拆分规则

 package com.FM.ArrayListStudy;

 import java.util.ArrayList;

 import java.util.Spliterator;

 public class SpliteratorInArrayListStudy {

     public static void main(String[] args) {

         // 初始化list

         ArrayList<Integer> list = new ArrayList<Integer>();

         for (int i = 0; i < 20; i++) {

             list.add(i + 1);

         }

         //四线程均分配比方式

         Spliterator<Integer> spliterator01 = list.spliterator();        　//01中有20个元素

         Spliterator<Integer> spliterator02 = spliterator01.trySplit();    //01中有10个元素,02中有10个元素

         Spliterator<Integer> spliterator03 = spliterator01.trySplit();    //01中有5个元素,02中有10个元素,03中有5个元素

         Spliterator<Integer> spliterator04 = spliterator02.trySplit();    //01中有5个元素,02中有5个元素,03中有5个元素,04中有5个元素

         MyThread4Spliterator<Integer> t01 = new MyThread4Spliterator<Integer>(spliterator01);

         MyThread4Spliterator<Integer> t02 = new MyThread4Spliterator<Integer>(spliterator02);

         MyThread4Spliterator<Integer> t03 = new MyThread4Spliterator<Integer>(spliterator03);

         MyThread4Spliterator<Integer> t04 = new MyThread4Spliterator<Integer>(spliterator04);

         t01.setName("001");

         t02.setName("002");

         t03.setName("003");

         t04.setName("004");

         t01.start();

         t02.start();

         t03.start();

         t04.start();

     }

 }

运行结果：

以上！！

巴特西

一点一点看JDK源码（五）java.util.ArrayList 后篇之Spliterator多线程遍历

目录：一点一点看JDK源码（〇）

最新文章

热门文章