Java迭代器并发

发布时间：2020-12-14 05:37:27 所属栏目：Java 来源：网络整理

导读：我正在尝试同时循环 Java迭代器,但是遇到麻烦的最佳方法. 这是我所拥有的,我不会尝试同时做任何事情. Long l; IteratorLong i = getUserIDs();while (i.hasNext()) { l = i.next(); someObject.doSomething(l); anotheObject.doSomething(l);} 我在非迭代器

我正在尝试同时循环 Java迭代器,但是遇到麻烦的最佳方法.

这是我所拥有的,我不会尝试同时做任何事情.

Long l;    
Iterator<Long> i = getUserIDs();

while (i.hasNext()) {
    l = i.next();

    someObject.doSomething(l);
    anotheObject.doSomething(l);
}

我在非迭代器对象上做的事情之间应该没有竞争条件,所以我不太担心.我只想通过不按顺序循环迭代迭代器所需的时间.

提前致谢.

解决方法

一种解决方案是使用执行程序来并行化您的工作.

简单的例子：

ExecutorService executor = Executors.newCachedThreadPool();

Iterator<Long> i = getUserIDs();
while (i.hasNext()) {
    final Long l = i.next();

    Runnable task = new Runnable() {
        public void run() {
            someObject.doSomething(l);
            anotheObject.doSomething(l);
        }
    }

    executor.submit(task);
}

executor.shutdown();

这将为迭代器中的每个项创建一个新线程,然后执行该工作.您可以通过在Executors类上使用不同的方法来调整使用的线程数,或者根据您的需要细分工作(例如,为每个方法调用使用不同的Runnable).

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!