我有一个方法:
invokList(List<Object> list);
这个方法在一个jar中,我无法访问它的源代码。因此,我需要以并行方式执行invokList,有人能帮我吗?
这个想法是将列表拆分为多个列表并并行执行invokList。
我举了一个例子:
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
public class Test {
public static void main(String[] args) {
List<Integer> 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<Integer> list) {
try {
Thread.sleep(100);
System.out.println("The Thread :" + Thread.currentThread().getName() + " is processing this list" + list);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
如果你不想带来额外的依赖项,比如番石榴,那么你可以编写一个收集器,将你的列表分成几块:
static <T> Collector<T, List<List<T>>, List<List<T>>> toChunks(int size) {
return Collector.of(ArrayList::new, (list, value) -> {
List<T> chunk = list.isEmpty() ? null : list.get(list.size() - 1);
if (chunk == null || chunk.size() == size) {
chunk = new ArrayList<>(size);
list.add(chunk);
}
chunk.add(value);
}, (list1, list2) -> {
throw new UnsupportedOperationException();
});
}
然后按以下方式进行命名:
List<Integer> list = Arrays.asList(1,26,17,18,19,20);
list.stream().collect(toChunks(5))
.parallelStream()
.forEach(System.out::println);
看起来很冗长,但您可以尝试以下方法。runAsync()
方法将使列表块并行运行。
private void test(List<Object> list, int chunkSize) throws ExecutionException, InterruptedException {
AtomicInteger prev = new AtomicInteger(0);
List<CompletableFuture> 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<Object> 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<Object> list) {
System.out.println("Invoked for: " + list);
}
我运行了一个包含30个整数的列表,块大小为5,如下所示:
public static void main(String[] args) throws ExecutionException, InterruptedException {
List<Object> list = IntStream.range(0, 30).mapToObj(i1 -> (Object) String.valueOf(i1)).collect(Collectors.toList());
int chunkSize = 5;
new Test().test(list, chunkSize);
}
输出:
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]
番石榴有很多方法。分割和不可分割。分区可以做你想做的事情。假设你有一个很大的列表,并且想把它分成5块来处理,你可以这样做:
int batchSize = 5;
Lists.partition(list, batchSize)
.parallelStream()
.forEach(batch -> invokeList(batch));
问题内容: 我有一个方法: 该方法位于jar中,我无法访问其源代码。因此,我需要以并行方式执行invokList,有人可以为此提供帮助吗? 想法是将列表拆分为多个列表,然后并行执行invokList。 我做了这个例子: 问题答案: 看起来很冗长,但是您可以尝试以下方法。该方法将使列表块并行运行。 我 为30个 整数 列表 运行,其 块大小为5, 如下所示: 输出 :
主要内容:1 Java8 方法参数反射的介绍,2 Method类,3 Method类的方法,4 Parameter类,5 Parameter类的方法,6 Java8 方法参数反射的案例1 Java8 方法参数反射的介绍 Java提供了一项新功能,您可以在其中获得任何方法或构造函数的形式参数的名称。java.lang.reflect包包含所有必需的类,例如Method和Parameter,可用于参数反射。 2 Method类 Method类提供有关类或接口上的单个方法的信息。反射的方法可以是类方法
我必须遍历一个列表,并为每个对象调用一个方法,但要并行。在循环之后,还有其他语句,它们必须等待并行方法调用。我如何在Java中做到这一点?
目前正在学习Java 8 lambda表达式和方法引用。 我想把一个没有参数和返回值的方法作为参数传递给另一个方法。我就是这样做的: 我知道如
我试图使用
问题内容: Varargs: 与 单数组参数: Java 1.6似乎接受/拒绝以下内容: 假设以上内容是正确的,为什么不总是使用varargs而不是单个数组参数呢?似乎免费增加了呼叫者的灵活性。 如果有,专家可以共享内部JVM的不同吗? 谢谢。 问题答案: 数组从Java的开始就出现了,而varargs是最近才添加的。因此,许多旧代码仍然很高兴地使用数组。 还要注意,使用显式数组参数调用通用var