文章/答案/技术大牛

发布

社区首页 >问答首页 >Java 1.6中多线程在For循环中的应用

问Java 1.6中多线程在For循环中的应用
EN

Stack Overflow用户

提问于 2018-04-26 18:32:16

回答 1查看 538关注 0票数 1

我试图在Java1.6中使用带有多线程的For循环。我尝试使用streams，但显然它是在Java1.8中添加的，所以我尝试了useExecutorService和未来，但我无法使它工作。

我想要的只是用固定数量的线程使这段代码多线程。

for (ExampleType ex : exampleData) {
    exampleFunction(ex.getSomeData());
}

我尝试但没有成功的东西，在谷歌的某个地方找到的

final ExecutorService testExecutor = Executors.newFixedThreadPool(10); // just 10 thread
final List<Future<?>> executeDatas = new ArrayList<List>();

for (ExampleType ex : exampleData) {
    Future<?> executeData = testExecutor.submit(() -> {
        exampleFunction(ex.getSomeData());
    });
    executeDatas.add(executeData);
}

for (Future<?> executeData : executeDatas) {
    executeData.done(); // do i need to write stuff here? i don't have done() function
}

这可能会奏效，但表示-source 1.6中不支持钻石运营商。是的，我不知道从这里怎么处理，被困住了。任何帮助都是非常感谢的。

java

multithreading

回答 1

Stack Overflow用户

回答已采纳

发布于 2018-04-26 19:05:15

由于某些原因，没有人显示转换后的代码，所以我将这样做：

final ExecutorService testExecutor = Executors.newFixedThreadPool(10);
final List<Future<?>> executeDatas = new ArrayList<Future<?>>();

for (ExampleType ex : exampleData) {
    Future<?> executeData = testExecutor.submit(new Runnable() {
        @Override
        public void run() {
            exampleFunction(ex.getSomeData());
        }
    });
    executeDatas.add(executeData);
}

for (Future<?> executeData : executeDatas) {
    // calling get in loop to effectively wait for all the futures to finish
    executeData.get();
}

作了三项修改：

将ArrayList<List>替换为ArrayList<Future<?>>
用匿名类实例化替换Lambda
.done()改为.get()，等待所有期货完成执行。

票数 3

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/50049810

复制

相似问题

问Java 1.6中多线程在For循环中的应用
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Java 1.6中多线程在For循环中的应用EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Java 1.6中多线程在For循环中的应用
EN