java.util.Collection.parallelStream()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(375)

本文整理了Java中java.util.Collection.parallelStream()方法的一些代码示例，展示了Collection.parallelStream()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Collection.parallelStream()方法的具体详情如下：
包路径：java.util.Collection
类名称：Collection
方法名：parallelStream

Collection.parallelStream介绍

暂无

代码示例

代码示例来源：origin: google/guava

  1. @Override
  2. public Stream<E> parallelStream() {
  3.  synchronized (mutex) {
  4.   return delegate().parallelStream();
  5.  }
  6. }

代码示例来源：origin: speedment/speedment

  1. @Override
  2.   public Stream<T> build(boolean parallel) {
  3.     return parallel ? collection.parallelStream() : collection.stream();
  4.   }
  5. }

代码示例来源：origin: prestodb/presto

  1. @Override
  2. public Stream<E> parallelStream() {
  3.  synchronized (mutex) {
  4.   return delegate().parallelStream();
  5.  }
  6. }

代码示例来源：origin: stackoverflow.com

  1. List<String> destList = new ArrayList<>(Arrays.asList("foo"));
  2. List<String> newList = Arrays.asList("0", "1", "2", "3", "4", "5");
  3. newList.parallelStream()
  4.     .collect(Collectors.toCollection(() -> destList));
  5. System.out.println(destList);

代码示例来源：origin: apache/storm

  1. private int fragmentedCpu() {
  2.   Double res = nodeIdToResources.get().values().parallelStream().filter(this::isFragmented)
  3.                  .mapToDouble(SupervisorResources::getAvailableCpu).filter(x -> x > 0).sum();
  4.   return res.intValue();
  5. }

代码示例来源：origin: apache/storm

  1. private double fragmentedMemory() {
  2.   Double res = nodeIdToResources.get().values().parallelStream().filter(this::isFragmented)
  3.                  .mapToDouble(SupervisorResources::getAvailableMem).filter(x -> x > 0).sum();
  4.   return res.intValue();
  5. }

代码示例来源：origin: qunarcorp/qmq

  1. @Override
  2.   public void destroy() {
  3.     groupSenders.values().parallelStream().forEach(SenderGroup::destroy);
  4.     groupSenders.clear();
  5.   }
  6. }

代码示例来源：origin: lets-blade/blade

  1. @Override
  2. public void run() {
  3.   try {
  4.     Collection<Session> sessions = sessionManager.sessionMap().values();
  5.     sessions.parallelStream().filter(this::expires).forEach(sessionManager::destorySession);
  6.   } catch (Exception e) {
  7.     log.error("Session clean error", e);
  8.   }
  9. }

代码示例来源：origin: lets-blade/blade

  1. @Override
  2. public void run() {
  3.   try {
  4.     Collection<Session> sessions = sessionManager.sessionMap().values();
  5.     sessions.parallelStream().filter(this::expires).forEach(sessionManager::destorySession);
  6.   } catch (Exception e) {
  7.     log.error("Session clean error", e);
  8.   }
  9. }

代码示例来源：origin: stackoverflow.com

  1. public static final int LIMIT = 500_000_000;
  2.   public static final long VALUE = 3L;
  4.   public long range() {
  5.     return
  6.       LongStream.range(0, LIMIT)
  7.         .parallel()
  8.         .map(i -> VALUE)
  9.         .map(i -> i % 73 % 13)
  10.         .sum();
  11. }
  13.   public long ncopies() {
  14.     return
  15.       Collections.nCopies(LIMIT, VALUE)
  16.         .parallelStream()
  17.         .mapToLong(i -> i)
  18.         .map(i -> i % 73 % 13)
  19.         .sum();
  20. }

代码示例来源：origin: wildfly/wildfly

  1. @Override
  2. public Stream<E> parallelStream() {
  3.  synchronized (mutex) {
  4.   return delegate().parallelStream();
  5.  }
  6. }

代码示例来源：origin: micronaut-projects/micronaut-core

  1. /**
  2.  * Scans the given package names.
  3.  *
  4.  * @param annotation The annotation name to scan
  5.  * @param packages   The package names
  6.  * @return A stream of classes
  7.  */
  8. default Stream<Class> scan(String annotation, Collection<String> packages) {
  9.   return scan(annotation, packages.parallelStream());
  10. }

代码示例来源：origin: micronaut-projects/micronaut-core

  1. /**
  2.  * Scans the given package names.
  3.  *
  4.  * @param annotation The annotation name to scan
  5.  * @param packages   The package names
  6.  * @return A stream of classes
  7.  */
  8. default Stream<Class> scan(Class<? extends Annotation> annotation, Collection<String> packages) {
  9.   return scan(annotation.getName(), packages.parallelStream());
  10. }

代码示例来源：origin: stackoverflow.com

  1. public abstract class MyOptimizedCollection<E> implements Collection<E>{
  2.   private enum OperatingSystem{
  3.     LINUX, WINDOWS, ANDROID
  4.   }
  5.   private OperatingSystem operatingSystem = OperatingSystem.WINDOWS;
  6.   private int numberOfCores = Runtime.getRuntime().availableProcessors();
  7.   private Collection<E> delegate;
  9.   @Override
  10.   public Stream<E> parallelStream() {
  11.     if (!System.getProperty("parallelSupport").equals("true")) {
  12.       return this.delegate.stream();
  13.     }
  14.     switch (operatingSystem) {
  15.       case WINDOWS:
  16.         if (numberOfCores > 3 && delegate.size() > 10000) {
  17.           return this.delegate.parallelStream();
  18.         }else{
  19.           return this.delegate.stream();
  20.         }
  21.       case LINUX:
  22.         return SomeVerySpecialStreamImplementation.stream(this.delegate.spliterator());
  23.       case ANDROID:
  24.       default:
  25.         return this.delegate.stream();
  26.     }
  27.   }
  28. }

代码示例来源：origin: hs-web/hsweb-framework

  1. Objects.requireNonNull(predicateFunction, "root predicate function can not be null");
  2. Supplier<Stream<N>> streamSupplier = () -> dataList.size() < 1000 ? dataList.stream() : dataList.parallelStream();

代码示例来源：origin: Vedenin/useful-java-links

  1. Stream<String> parallelStream = collection.parallelStream();
  2. System.out.println("parallelStream = " + parallelStream.collect(Collectors.toList())); // print  parallelStream = [a1, a2, a3]

代码示例来源：origin: qunarcorp/qmq

  1. void reValidate(final Map<Long, Long> offsets, int singleMessageLimitSize) {
  2.   segments.values().parallelStream().forEach(segment -> {
  3.     Long offset = offsets.get(segment.getSegmentBaseOffset());
  4.     long wrotePosition = segment.getWrotePosition();
  5.     if (null == offset || offset != wrotePosition) {
  6.       offset = doValidate((ScheduleSetSegment) segment, singleMessageLimitSize);
  7.     } else {
  8.       offset = wrotePosition;
  9.     }
  10.     ((ScheduleSetSegment) segment).loadOffset(offset);
  11.   });
  12. }

代码示例来源：origin: meituan/WMRouter

  1. input.getJarInputs().parallelStream().forEach(jarInput -> {
  2.   File src = jarInput.getFile();
  3.   File dst = invocation.getOutputProvider().getContentLocation(
  4. input.getDirectoryInputs().parallelStream().forEach(directoryInput -> {
  5.   File src = directoryInput.getFile();
  6.   File dst = invocation.getOutputProvider().getContentLocation(

代码示例来源：origin: opentripplanner/OpenTripPlanner

  1. public StopTreeCache (Graph graph, int maxWalkMeters) {
  2.   this.maxWalkMeters = maxWalkMeters;
  3.   LOG.info("Caching distances to nearby street intersections from each transit stop...");
  4.   graph.index.stopVertexForStop.values().parallelStream().forEach(tstop -> {
  5.     RoutingRequest rr = new RoutingRequest(TraverseMode.WALK);
  6.     rr.batch = (true);

代码示例来源：origin: micronaut-projects/micronaut-core

  1. private void processHttpMethods(Collection<BeanDefinition<?>> clientBeans) {
  2.   for (BeanDefinition<?> clientBean : clientBeans) {
  3.     final Optional<Class[]> additionalTypes = clientBean.getValue(TypeHint.class, Class[].class);
  4.     additionalTypes.ifPresent(classes -> {
  5.       for (Class aClass : classes) {
  6.         ClassLoadingReporter.reportBeanPresent(aClass);
  7.       }
  8.     });
  9.     final Collection<? extends ExecutableMethod<?, ?>> executableMethods = clientBean.getExecutableMethods();
  10.     executableMethods.parallelStream().forEach((Consumer<ExecutableMethod<?, ?>>) executableMethod -> {
  11.       if (executableMethod.hasStereotype(HttpMethodMapping.class)) {
  12.         final ReturnType<?> returnType = executableMethod.getReturnType();
  13.         final Class<?> javaType = returnType.getType();
  14.         if (!ClassUtils.isJavaLangType(javaType)) {
  15.           ClassLoadingReporter.reportBeanPresent(javaType);
  16.         }
  17.         reportArguments(returnType.getTypeParameters());
  18.         reportArguments(executableMethod.getArguments());
  19.       }
  20.     });
  21.   }
  22. }

内容来源于网络，如有侵权，请联系作者删除！

Collection

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com