在 Java 中将列表迭代器传递给多个线程

我有一个包含大约 200K 元素的列表。

我是否能够将此列表的迭代器传递给多个线程，并让它们迭代整个列表，而没有任何一个线程访问相同的元素？

这就是我此刻的想法。

Main:

public static void main(String[] args)
{
    // Imagine this list has the 200,000 elements.
    ArrayList<Integer> list = new ArrayList<Integer>();

    // Get the iterator for the list.
    Iterator<Integer> i = list.iterator();

    // Create MyThread, passing in the iterator for the list.
    MyThread threadOne = new MyThread(i);
    MyThread threadTwo = new MyThread(i);
    MyThread threadThree = new MyThread(i);

    // Start the threads.
    threadOne.start();
    threadTwo.start();
    threadThree.start();
}

我的主题：

public class MyThread extends Thread
{

    Iterator<Integer> i;

    public MyThread(Iterator<Integer> i)
    {
        this.i = i;
    }

    public void run()
    {
        while (this.i.hasNext()) {
            Integer num = this.i.next();
            // Do something with num here.
        }
    }
}

我期望的结果是每个线程将处理大约 66,000 个元素，而不会过多锁定迭代器，并且也没有任何线程访问同一元素。

这听起来可行吗？

Do you really需要手动操作线程和迭代器？你可以使用Java 8Stream并让parallel()做这份工作。

默认情况下，当您拥有处理器时，它将少使用一个线程。

例子 ：

list.stream()
    .parallel()
    .forEach(this::doSomething)
;

//For example, display the current integer and the current thread number.
public void doSomething(Integer i) {
  System.out.println(String.format("%d, %d", i, Thread.currentThread().getId()));
}

结果 ：

49748, 13
49749, 13
49750, 13
192710, 14
105734, 17
105735, 17
105736, 17
[...]

编辑：如果你使用maven，你将需要添加这段配置pom.xml为了使用Java 8：

<build>
  <plugins>
    <plugin>
      <groupId>org.apache.maven.plugins</groupId>
      <artifactId>maven-compiler-plugin</artifactId>
      <version>3.3</version>
      <configuration>
        <source>1.8</source>
        <target>1.8</target>
      </configuration>
    </plugin>
  </plugins>
</build>