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

ConcurrentSkipListSet.stream介绍

暂无

代码示例

代码示例来源：origin: de.otto.synapse/synapse-core

@Override
@SuppressWarnings("unchecked")
public Stream<Message<String>> stream() {
  return compactedAndOrderedKeys.stream().map(messages::get).map(this::toStringMessage);
}

代码示例来源：origin: maisi/M365-Power

public static double getAverageSpeed() {
  double sum =averageSpeedList.stream().mapToDouble(Double::doubleValue).sum();
  double avgEff = (sum / averageSpeedList.size());
  return avgEff;
}

代码示例来源：origin: maisi/M365-Power

public static int getAverageEfficiency() {
  if(efficiencyList.size()==0){
    return 600; //just started app, no values yet
  }
  double sum =efficiencyList.stream().mapToDouble(Double::doubleValue).sum();
  double avgEff = (sum / efficiencyList.size());
  return (int)avgEff;
}

代码示例来源：origin: de.pfabulist.lindwurm/stellvertreter

} else {
  if ( !files.stream().
      filter( hf ->  here.getElsewhereAdmin().deleteHereOnly( hf )).
      findFirst().

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

/**
 * This method maintains a sorted list of position for requests currently being processed.
 * As processing of each request completes, it is removed from the sorted list and moved to
 * completed list.
 * Completed is also a sorted list that contains all completed requests greater than smallest running position.
 * In other words, we maintain all requests from smallest processing to current position in either running or completed
 * sorted list.
 * Note: Smallest position will always be in the running list.
 * We also maintain a single checkpoint, which is the highest completed position smaller than smallest running position.
 *
 * @param pc position for which processing completed
 */
@Synchronized
private void checkpoint(PositionCounter pc) {
  running.remove(pc);
  completed.add(pc);
  final PositionCounter smallest = running.isEmpty() ? MAX : running.first();
  final List<PositionCounter> checkpointCandidates = completed.stream()
      .filter(x -> positionCounterComparator.compare(x, smallest) < 0).collect(Collectors.toList());
  if (checkpointCandidates.size() > 0) {
    final PositionCounter checkpointPosition = checkpointCandidates.get(checkpointCandidates.size() - 1);
    completed.removeAll(checkpointCandidates);
    checkpoint.set(checkpointPosition);
  }
}

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

@Override
protected void doStop() {
  Futures.allOf(buckets.stream().map(bucketService -> {
    CompletableFuture<Void> bucketFuture = new CompletableFuture<>();
    bucketService.addListener(new Listener() {
      @Override
      public void terminated(State from) {
        super.terminated(from);
        bucketFuture.complete(null);
      }
      @Override
      public void failed(State from, Throwable failure) {
        super.failed(from, failure);
        bucketFuture.completeExceptionally(failure);
      }
    }, executor);
    bucketService.stopAsync();
    return bucketFuture;
  }).collect(Collectors.toList()))
      .whenComplete((r, e) -> {
        streamMetadataStore.unregisterBucketOwnershipListener();
        if (e != null) {
          notifyFailed(e);
        } else {
          notifyStopped();
        }
      });
}

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

private CompletableFuture<Void> tryTakeOwnership(int bucket) {
  return RetryHelper.withIndefiniteRetriesAsync(() -> streamMetadataStore.takeBucketOwnership(bucket, processId, executor),
      e -> log.warn("exception while attempting to take ownership"), executor)
      .thenCompose(isOwner -> {
        if (isOwner && buckets.stream().noneMatch(x -> x.getBucketId() == bucket)) {
          log.info("Taken ownership for bucket {}", bucket);
          StreamCutBucketService bucketService = new StreamCutBucketService(bucket, streamMetadataStore,
              streamMetadataTasks, executor, requestTracker);
          buckets.add(bucketService);
          CompletableFuture<Void> bucketFuture = new CompletableFuture<>();
          bucketService.addListener(new Listener() {
            @Override
            public void running() {
              super.running();
              bucketFuture.complete(null);
            }
            @Override
            public void failed(State from, Throwable failure) {
              super.failed(from, failure);
              bucketFuture.completeExceptionally(failure);
            }
          }, executor);
          bucketService.startAsync();
          return bucketFuture;
        } else {
          return CompletableFuture.completedFuture(null);
        }
      });
}

代码示例来源：origin: maisi/M365-Power

currentSum += d;
double speedSum = speedList.stream().mapToDouble(Double::doubleValue).sum();
double averageCurrent = (currentSum / currentList.size());
double averageSpeed = speedSum / speedList.size();