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

DoubleStream.forEach介绍

[英]Performs an action for each element of this stream.

This is a terminal operation.

For parallel stream pipelines, this operation does not guarantee to respect the encounter order of the stream, as doing so would sacrifice the benefit of parallelism. For any given element, the action may be performed at whatever time and in whatever thread the library chooses. If the action accesses shared state, it is responsible for providing the required synchronization.
[中]为此流的每个元素执行操作。
这是一个terminal operation。
对于并行流管道，此操作不保证尊重流的相遇顺序，因为这样做会牺牲并行性的好处。对于任何给定的元素，可以在库选择的任何时间和线程中执行该操作。如果操作访问共享状态，则它负责提供所需的同步。

代码示例

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

private static void saveDataFile(String location, String name,
                 DescriptiveStatistics data, TimeUnit scale) {
 long conv = scale.toNanos(1);
 Path dst = Paths.get(location, name);
 try (PrintStream output = new PrintStream(dst.toString())) {
  // Print all values one per line
  Arrays.stream(data.getValues()).forEach(d -> output.println(d / conv));
 } catch (FileNotFoundException e) {
  LOG.error("failed to write to {}", dst);
 }
}

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

@Override
  public Void execute() {
    try (final DoubleStream stream = buildPrevious()) {
      stream.forEach(consumer);
    }
    
    return null;
  }
}

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

default <T> void forEach(DoublePipeline pipeline, DoubleConsumer action) {
  requireNonNull(pipeline);
  requireNonNull(action);
  optimize(pipeline).getAsDoubleStream().forEach(action);
}

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

@Override
public void forEach(DoubleConsumer action) {
  finallyClose(() -> stream().forEach(action));
}

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

public void testStream() {
 ImmutableDoubleArray.of().stream().forEach(i -> fail());
 ImmutableDoubleArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail());
 assertThat(ImmutableDoubleArray.of(0, 1, 3).stream().toArray())
   .isEqualTo(new double[] {0, 1, 3});
}

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

private Object getExpectedValueDoubles(double maxError, double... values)
{
  if (values.length == 0) {
    return null;
  }
  QuantileDigest qdigest = new QuantileDigest(maxError);
  Arrays.stream(values).forEach(value -> qdigest.add(doubleToSortableLong(value)));
  return new SqlVarbinary(qdigest.serialize().getBytes());
}

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

double[] array = {1, 6, 7, 3, 3, 1, 2, 8, 9, 7, 3};

Arrays.stream(array, 3, 6).forEach((d) -> {
  System.out.println(d);
});

OR

IntStream.range(3, 6).mapToDouble(i -> array[i]).forEach(d -> {
  System.out.println(d);
});

代码示例来源：origin: com.simiacryptus/java-util

/**
 * Accept double statistics.
 *
 * @param value the value
 * @return the double statistics
 */
@javax.annotation.Nonnull
public com.simiacryptus.util.data.DoubleStatistics accept(@javax.annotation.Nonnull final double[] value) {
 Arrays.stream(value).forEach(this::accept);
 return this;
}

代码示例来源：origin: com.simiacryptus/java-util

/**
 * Stats scalar statistics.
 *
 * @param data the data
 * @return the scalar statistics
 */
@javax.annotation.Nonnull
public static com.simiacryptus.util.data.ScalarStatistics stats(@javax.annotation.Nonnull final double[] data) {
 @javax.annotation.Nonnull final com.simiacryptus.util.data.ScalarStatistics statistics = new PercentileStatistics();
 Arrays.stream(data).forEach(statistics::add);
 return statistics;
}

代码示例来源：origin: se.ugli.ugli-commons/ugli-commons

@Override
public void forEach(final DoubleConsumer action) {
  // This is a terminal operation
  executeAndClose(() -> stream.forEach(action));
}

代码示例来源：origin: com.speedment.runtime/runtime-core

default <T> void forEach(DoublePipeline pipeline, DoubleConsumer action) {
  requireNonNull(pipeline);
  requireNonNull(action);
  optimize(pipeline).getAsDoubleStream().forEach(action);
}

代码示例来源：origin: com.speedment.runtime/runtime-core

@Override
public void forEach(DoubleConsumer action) {
  finallyClose(() -> stream().forEach(action));
}

代码示例来源：origin: zavtech/morpheus-core

/**
 * Retruns the integer bounds of a stream of doubles
 * @param stream    the stream to compute bounds on
 * @return          the bounds for stream, empty if no data in stream
 */
public static Optional<Bounds<Double>> ofDoubles(DoubleStream stream) {
  final OfDoubles calculator = new OfDoubles();
  stream.forEach(calculator::add);
  return calculator.getBounds();
}

代码示例来源：origin: mzheravin/exchange-core

public static Map<String, String> createLatencyReportFast(Histogram histogram) {
  Map<String, String> fmt = new LinkedHashMap<>();
  Arrays.stream(PERCENTILES).forEach(p -> {
    String formattedValue = formatLatencyValueAsTime((int) histogram.getValueAtPercentile(p));
    fmt.put(p + "%", formattedValue);
  });
  fmt.put("W", formatLatencyValueAsTime((int) histogram.getMaxValue()));
  return fmt;
}

代码示例来源：origin: padreati/rapaio

@Override
public Range buildRange() {
  rebuild();
  Range range = new Range();
  range.union(minValue, Double.NaN);
  range.union(maxValue, Double.NaN);
  Arrays.stream(freqTable).sequential().forEach(t -> range.union(Double.NaN, t));
  range.union(Double.NaN, 0);
  return range;
}

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

@Override
protected Factory<DoubleSummary> factory() {
  return () -> {
    final Random random = RandomRegistry.getRandom();
    final DoubleSummaryStatistics statistics = new DoubleSummaryStatistics();
    IntStream.range(0, 100)
      .mapToDouble(i -> random.nextDouble())
      .forEach(statistics);
    return DoubleSummary.of(statistics);
  };
}

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

private Object getExpectedValueDoubles(double maxError, double... values)
{
  if (values.length == 0) {
    return null;
  }
  QuantileDigest qdigest = new QuantileDigest(maxError);
  Arrays.stream(values).forEach(value -> qdigest.add(doubleToSortableLong(value)));
  return new SqlVarbinary(qdigest.serialize().getBytes());
}

代码示例来源：origin: io.prestosql/presto-main

private Object getExpectedValueDoubles(double maxError, double... values)
{
  if (values.length == 0) {
    return null;
  }
  QuantileDigest qdigest = new QuantileDigest(maxError);
  Arrays.stream(values).forEach(value -> qdigest.add(doubleToSortableLong(value)));
  return new SqlVarbinary(qdigest.serialize().getBytes());
}

代码示例来源：origin: com.google.guava/guava-tests

public void testStream() {
 ImmutableDoubleArray.of().stream().forEach(i -> fail());
 ImmutableDoubleArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail());
 assertThat(ImmutableDoubleArray.of(0, 1, 3).stream().toArray())
   .isEqualTo(new double[] {0, 1, 3});
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testDoubleToArray() {
 Cache<Double, String> cache = getCache(0);
 int range = 10;
 // First populate the cache with a bunch of values
 DoubleStream.iterate(0.0, d -> d + .5).limit(10).boxed().forEach(i -> cache.put(i, i + "-value"));
 assertEquals(range, cache.size());
 CacheSet<Map.Entry<Double, String>> entrySet = cache.entrySet();
 double[] array = createStream(entrySet).mapToDouble(toDouble).toArray();
 assertEquals(cache.size(), array.length);
 Spliterator.OfDouble spliterator = Spliterators.spliterator(array, Spliterator.DISTINCT);
 StreamSupport.doubleStream(spliterator, true).forEach(e -> assertTrue(cache.containsKey(e)));
}