一点一点看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();
    }
}

运行结果：

以上！！