java 参数列表,Java 8方法参数列表的并行流

男娘i 2022-08-30 11:18 177阅读 0赞

![Image 1][]

I have a method:

invokList(List list);

This method is inside a jar and I have no access to the source code of it. So for that, I need to execute the invokList in a parallel way, can someone help for this?

The idea is to split the list to many lists and execute invokList in parallel.

I have made this example:

import java.util.Arrays;

import java.util.Collections;

import java.util.List;

public class Test \{

public static void main(String\[\] args) \{

List list = Arrays.asList(1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20);

list.parallelStream()

.map(Collections::singletonList)

.forEach(Test::invokList);

\}

public static void invokList(List list) \{

try \{

Thread.sleep(100);

System.out.println("The Thread :" + Thread.currentThread().getName() + " is processing this list" + list);

\} catch (InterruptedException e) \{

e.printStackTrace();

\}

\}

\}

解决方案

Looks very verbose, but you can try the following. The runAsync() method will make the list chunks run in parallel.

private void test(List list, int chunkSize) throws ExecutionException, InterruptedException \{

AtomicInteger prev = new AtomicInteger(0);

List futures = new ArrayList<>();

IntStream.range(1, (int) (chunkSize \* (Math.ceil(Math.abs(list.size() / (double) chunkSize)))))

.filter(i -> i % chunkSize == 0 || i == list.size())

.forEach(i -> \{

List chunk = list.subList(prev.get(), i);

futures.add(CompletableFuture.runAsync(() -> invokeList(chunk)));

prev.set(i);

\});

CompletableFuture.allOf(futures.toArray(new CompletableFuture\[0\])).get();

\}

private void invokeList(List list) \{

System.out.println("Invoked for: " + list);

\}

I ran it for a list of 30 integers, with a chunk size of 5 like this:

public static void main(String\[\] args) throws ExecutionException, InterruptedException \{

List list = IntStream.range(0, 30).mapToObj(i1 -> (Object) String.valueOf(i1)).collect(Collectors.toList());

int chunkSize = 5;

new Test().test(list, chunkSize);

\}

Output:

Invoked for: \[15, 16, 17, 18, 19\]

Invoked for: \[0, 1, 2, 3, 4\]

Invoked for: \[5, 6, 7, 8, 9\]

Invoked for: \[10, 11, 12, 13, 14\]

Invoked for: \[20, 21, 22, 23, 24\]

[Image 1]:

发表评论取消回复

表情：

评论列表（有 0 条评论，177人围观）

还没有评论，来说两句吧...

相关阅读

相关【Java基础知识 26】可变参数列表

![在这里插入图片描述][569c93ff22054aa0becb19f681aec5cf.gif_pic_center] 目录一、可变参数列表

青旅半醒/ 2024年03月17日 09:55/ 0 赞/ 68 阅读

相关 Java 参数类型后面三个点，可变参数列表

今天在看 springboot 中 mail 源码的时候，发现这个有趣的写法，参数类型后面三个点 ![watermark_type_ZmFuZ3poZW5naGVpdGk_s

冷不防/ 2023年06月25日 03:20/ 0 赞/ 152 阅读

相关 Java 8 并行流串行流

命令大全 1-容器生命周期管理 1.1-run 1.2-start/stop/restart 1.3-kill

骑猪看日落/ 2022年09月23日 11:56/ 0 赞/ 190 阅读

相关 java 参数列表,Java 8方法参数列表的并行流

![Image 1][] I have a method: invokList(List list); This method is inside a jar and I

男娘i/ 2022年08月30日 11:18/ 0 赞/ 178 阅读

相关可变参数列表（...）

如果有一组事物，可以把它们当作列表传递，如果有了一个数组，可把它们当作可变参数类表传递 java SE5之前可变参数列表 public class ke

秒速五厘米/ 2022年08月18日 11:38/ 0 赞/ 238 阅读

相关浅析可变参数列表

可不参数列表可以让函数在不同时候接受不同数目的参数。 C语言可变参数列表使用总可分为4个部分. 1、va\_list 首先，我们先来看一下它的定义： \ifdef

本是古典何须时尚/ 2022年07月30日 13:51/ 0 赞/ 260 阅读

相关 java小程序之可变长参数列表

可以把类型相同但个数可变的参数传递给方法。参数声明方式： typeName…parameterName( 类型名 … 参数名 ) 示例代码如下： //可

r囧r小猫/ 2022年07月28日 00:26/ 0 赞/ 174 阅读

相关 paypal 参数列表备忘录

<input type="hidden" name="business" value="nailwl\_125620

╰半夏微凉°/ 2022年07月14日 01:57/ 0 赞/ 149 阅读

相关 java虚拟机参数列表详细介绍基于java8

状态选项说明 <table> <thead> <tr> <th>参数</th> <th>描述</th> </tr> </thead>

喜欢ヅ旅行/ 2022年04月10日 03:25/ 0 赞/ 226 阅读

相关 java通过反射+javassist获得方法所有信息(返回值、方法名、参数类型列表、参数列表)

众所周知，使用java的反射无法获得方法参数名列表，只能获得方法参数类型列表，在网上研究了一下，发现有下面两种方式实现：方案一：使用反射+javassit库 st

亦凉/ 2021年06月24日 14:34/ 0 赞/ 431 阅读