本文整理了Java中java.util.stream.Stream.parallel()
方法的一些代码示例,展示了Stream.parallel()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Stream.parallel()
方法的具体详情如下:
包路径:java.util.stream.Stream
类名称:Stream
方法名:parallel
暂无
代码示例来源:origin: google/guava
@Override
public Stream<E> parallelStream() {
return stream().parallel();
}
代码示例来源:origin: testcontainers/testcontainers-java
@Override
public void stop() {
Stream.<Runnable>of(super::stop, proxy::stop).parallel().forEach(Runnable::run);
}
}
代码示例来源:origin: prestodb/presto
@Override
public Stream<E> parallelStream() {
return stream().parallel();
}
代码示例来源:origin: Vedenin/useful-java-links
/** 8. Using Java 8 Stream Api parallel **/
@Benchmark
public long test8_UsingJava8StreamApiParallel() throws IOException {
final long[] i = {0};
map.entrySet().stream().parallel().forEach(e -> i[0] += e.getKey() + e.getValue());
return i[0];
}
代码示例来源:origin: testcontainers/testcontainers-java
@Override
public void stop() {
stopCluster();
Stream.<Runnable>of(super::stop, proxy::stop).parallel().forEach(Runnable::run);
}
代码示例来源:origin: micronaut-projects/micronaut-core
/**
* Scans the given package names.
*
* @param annotation The annotation name to scan
* @param packages The package names
* @return A stream of classes
*/
default Stream<Class> scan(String annotation, Stream<String> packages) {
return packages
.parallel()
.flatMap(pkg -> scan(annotation, pkg));
}
代码示例来源:origin: speedment/speedment
@Override
@SuppressWarnings("unchecked")
public CompletableFuture<Boolean> verify() {
final CompletableFuture<Boolean>[] futures;
futures = rules.stream().parallel()
.map( Rule::verify )
.toArray( CompletableFuture[]::new );
return CompletableFutureUtil.allOf(Boolean.TRUE, Boolean::logicalAnd, futures);
}
}
代码示例来源:origin: micronaut-projects/micronaut-core
/**
* Scan the given packages.
*
* @param annotation The annotation to scan for
* @param packages The packages to scan
* @return A stream of classes
*/
default Stream<Class> scan(String annotation, Package... packages) {
return Arrays.stream(packages)
.parallel()
.flatMap(pkg -> scan(annotation, pkg.getName()));
}
代码示例来源:origin: wildfly/wildfly
@Override
public Stream<E> parallelStream() {
return stream().parallel();
}
代码示例来源:origin: speedment/speedment
@Override
public Stream<T> parallel() {
return toStream().parallel();
}
代码示例来源:origin: Vedenin/useful-java-links
@Benchmark
public String jdkJava8parallel() throws IOException {
mark();
String result = new BufferedReader(new InputStreamReader(inputStream)).lines().parallel().collect(Collectors.joining("\n"));
reset();
return result;
}
代码示例来源:origin: Vedenin/useful-java-links
@Benchmark
public String test5_jdkJava8parallel() throws IOException {
mark();
String result = new BufferedReader(new InputStreamReader(inputStream)).lines().parallel().collect(Collectors.joining("\n"));
reset();
return result;
}
代码示例来源:origin: goldmansachs/gs-collections
@Benchmark
public void parallel_lazy_jdk()
{
Map<Alphagram, Set<String>> groupBy = this.jdkWords.parallelStream().collect(Collectors.groupingBy(Alphagram::new, Collectors.<String>toSet()));
groupBy.entrySet()
.parallelStream()
.map(Map.Entry::getValue)
.filter(list -> list.size() >= SIZE_THRESHOLD)
.sorted(Comparator.<Set<String>>comparingInt(Set::size).reversed())
.parallel()
.map(list -> list.size() + ": " + list)
.forEach(e -> Assert.assertFalse(e.isEmpty()));
}
代码示例来源:origin: goldmansachs/gs-collections
@Benchmark
public void parallel_lazy_streams_gsc()
{
Map<Alphagram, Set<String>> groupBy = this.gscWords.parallelStream().collect(Collectors.groupingBy(Alphagram::new, Collectors.<String>toSet()));
groupBy.entrySet()
.parallelStream()
.map(Map.Entry::getValue)
.filter(list -> list.size() >= SIZE_THRESHOLD)
.sorted(Comparator.<Set<String>>comparingInt(Set::size).reversed())
.parallel()
.map(list -> list.size() + ": " + list)
.forEach(e -> Assert.assertFalse(e.isEmpty()));
}
代码示例来源:origin: apache/nifi
private void drainResponses(final Set<NodeResponse> responses, final NodeResponse exclude) {
responses.stream()
.parallel() // "parallelize" the draining of the responses, since we have multiple streams to consume
.filter(response -> response != exclude) // don't include the explicitly excluded node
.filter(response -> response.getStatus() != RequestReplicator.NODE_CONTINUE_STATUS_CODE) // don't include any continue responses because they contain no content
.forEach(response -> drainResponse(response)); // drain all node responses that didn't get filtered out
}
代码示例来源:origin: google/guava
public void testForEachPair_parallel() {
Stream<String> streamA = IntStream.range(0, 100000).mapToObj(String::valueOf).parallel();
Stream<Integer> streamB = IntStream.range(0, 100000).mapToObj(i -> i).parallel();
AtomicInteger count = new AtomicInteger(0);
Streams.forEachPair(
streamA,
streamB,
(a, b) -> {
count.incrementAndGet();
Truth.assertThat(a.equals(String.valueOf(b))).isTrue();
});
Truth.assertThat(count.get()).isEqualTo(100000);
// of course, this test doesn't prove that anything actually happened in parallel...
}
代码示例来源:origin: speedment/speedment
@Override
public Stream<T> parallel() {
return wrap(stream().parallel());
}
代码示例来源:origin: google/guava
public void testConcat_refStream_parallel() {
Truth.assertThat(
Streams.concat(Stream.of("a"), Stream.of("b"), Stream.empty(), Stream.of("c", "d"))
.parallel()
.toArray())
.asList()
.containsExactly("a", "b", "c", "d")
.inOrder();
}
代码示例来源:origin: spring-projects/spring-framework
@Test
public void invokeTestContextManagerFromConcurrentThreads() {
TestContextManager tcm = new TestContextManager(TestCase.class);
// Run the actual test several times in order to increase the chance of threads
// stepping on each others' toes by overwriting the same mutable state in the
// TestContext.
IntStream.range(1, 20).forEach(i -> {
actualMethods.clear();
// Execute TestExecutionListener in parallel, thereby simulating parallel
// test method execution.
stream(TestCase.class.getDeclaredMethods()).parallel().forEach(testMethod -> {
try {
tcm.beforeTestClass();
tcm.beforeTestMethod(testInstance, testMethod);
// no need to invoke the actual test method
tcm.afterTestMethod(testInstance, testMethod, null);
tcm.afterTestClass();
}
catch (Exception ex) {
throw new RuntimeException(ex);
}
});
assertThat(actualMethods, equalTo(expectedMethods));
});
assertEquals(0, tcm.getTestContext().attributeNames().length);
}
代码示例来源:origin: prestodb/presto
public void generate()
throws Exception
{
initPlanTest();
try {
getQueryResourcePaths()
.parallel()
.forEach(queryResourcePath -> {
try {
Path queryPlanWritePath = Paths.get(
getSourcePath().toString(),
"src/test/resources",
getQueryPlanResourcePath(queryResourcePath));
createParentDirs(queryPlanWritePath.toFile());
write(generateQueryPlan(read(queryResourcePath)).getBytes(UTF_8), queryPlanWritePath.toFile());
System.out.println("Generated expected plan for query: " + queryResourcePath);
}
catch (IOException e) {
throw new UncheckedIOException(e);
}
});
}
finally {
destroyPlanTest();
}
}
内容来源于网络,如有侵权,请联系作者删除!