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

LongStream.rangeClosed介绍

暂无

代码示例

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

@Override
public List<Long> getTxnIds() {
 if (txnIds != null) {
  return txnIds;
 }
 return LongStream.rangeClosed(fromTxnId, toTxnId)
     .boxed().collect(Collectors.toList());
}

代码示例来源：origin: shekhargulati/99-problems

public static boolean isPrime(long number) {
    return !LongStream.rangeClosed(2, Math.round(Math.sqrt(number))).anyMatch(n -> number % n == 0);
  }
}

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

/**
 * Returns all updates in the specified range of versions.
 *
 * @param startVer Lower bound (inclusive).
 * @param actualVer Upper bound (inclusive).
 * @return Array with all requested updates sorted by version in ascending order.
 */
private DistributedMetaStorageHistoryItem[] history(long startVer, long actualVer) {
  return LongStream.rangeClosed(startVer, actualVer)
    .mapToObj(this::historyItem)
    .toArray(DistributedMetaStorageHistoryItem[]::new);
}

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

public static long factorial(final int n) {
  if (n > 20 || n < 0) {
    throw new IllegalArgumentException(n + " is out of range");
  }
  return LongStream.rangeClosed(2, n).reduce(1, (a, b) -> a * b);
}

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

/**
 * Gets a stream of values from a range.
 */
public static LongStream rangeValues(Protos.Value.Range range) {
  checkNotNull(range);
  return LongStream.rangeClosed(range.getBegin(), range.getEnd());
}

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

private List<Long> replOpenTxnForTest(long startId, int numTxn, String replPolicy)
    throws Exception {
 conf.setIntVar(HiveConf.ConfVars.HIVE_TXN_MAX_OPEN_BATCH, numTxn);
 long lastId = startId + numTxn - 1;
 OpenTxnRequest rqst = new OpenTxnRequest(numTxn, "me", "localhost");
 rqst.setReplPolicy(replPolicy);
 rqst.setReplSrcTxnIds(LongStream.rangeClosed(startId, lastId)
     .boxed().collect(Collectors.toList()));
 OpenTxnsResponse openedTxns = txnHandler.openTxns(rqst);
 List<Long> txnList = openedTxns.getTxn_ids();
 assertEquals(txnList.size(), numTxn);
 int numTxnPresentNow = TxnDbUtil.countQueryAgent(conf, "select count(*) from TXNS where TXN_ID >= " +
     txnList.get(0) + " and TXN_ID <= " + txnList.get(numTxn - 1));
 assertEquals(numTxn, numTxnPresentNow);
 checkReplTxnForTest(startId, lastId, replPolicy, txnList);
 return txnList;
}

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

String[] output = TxnDbUtil.queryToString(conf, "select ntxn_next from NEXT_TXN_ID").split("\n");
long startTxnId = Long.parseLong(output[1].trim());
List<Long> srcTxnIdList = LongStream.rangeClosed(startTxnId, numTxn+startTxnId-1)
    .boxed().collect(Collectors.toList());
List<Long> targetTxnList = replOpenTxnForTest(startTxnId, numTxn, "destdb.*");

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

return LongStream.rangeClosed( lower, upper );

代码示例来源：origin: palantir/atlasdb

private static Multimap<Cell, Value> getVersions() {
    Multimap<Cell, Value> versions = ArrayListMultimap.create();
    LongStream.rangeClosed(1, CELL_VERSIONS).boxed()
        .forEach(timestamp -> versions.put(cell, Value.create(value, timestamp)));
    return versions;
  }
}

代码示例来源：origin: BruceEckel/OnJava8-Examples

public static boolean isPrime(long n) {
 return rangeClosed(2, (long)Math.sqrt(n))
  .noneMatch(i -> n % i == 0);
}
public LongStream numbers() {

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

import java.util.stream.LongStream;

public class ParallelPlay {

  public static void main(String[] args) {
    System.out.println(parallelSum(100_000_000));
  }

  public static long parallelSum(long n) {
    return LongStream.rangeClosed(1, n).parallel().sum();
  }
}

代码示例来源：origin: BruceEckel/OnJava8-Examples

public static boolean isPrime(long n) {
 return rangeClosed(2, (long)Math.sqrt(n))
  .noneMatch(i -> n % i == 0);
}
public static void main(String[] args)

代码示例来源：origin: one.util/streamex

/**
 * Returns a sequential ordered {@code LongStreamEx} from
 * {@code startInclusive} (inclusive) to {@code endInclusive} (inclusive) by
 * an incremental step of {@code 1}.
 *
 * @param startInclusive the (inclusive) initial value
 * @param endInclusive the inclusive upper bound
 * @return a sequential {@code LongStreamEx} for the range of {@code long}
 *         elements
 * @see LongStream#rangeClosed(long, long)
 */
public static LongStreamEx rangeClosed(long startInclusive, long endInclusive) {
  return seq(LongStream.rangeClosed(startInclusive, endInclusive));
}

代码示例来源：origin: com.commercetools.sunrise/common

protected List<LinkBean> createPages(final Pagination pagination, final long startPage, final long endPage) {
  return LongStream.rangeClosed(startPage, endPage)
      .mapToObj(page -> createLinkData(pagination, page))
      .collect(toList());
}

代码示例来源：origin: rpatil26/webutilities

public static void main(String[] args) {
  System.out.println("Hello World!");
  /*Executor exec = Executors.newCachedThreadPool();
  for(int i = 0; i < 20; i++) {
    final int v = i;
    exec.execute(new Runnable() {
      @Override
      public void run() {
        System.out.println(v);
      }
    });
  }*/
  LongStream.rangeClosed(0, 5).map(n -> n * n).forEach(s -> System.out.print(s + " "));
}

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

private static void execIntegerRangeOpcodes(StackFrame sf, int[] operands) {
  int i = operands[0];
  int j = operands[1];
  int k = operands[2];
  sf.refRegs[k] = new BValueArray(LongStream.rangeClosed(sf.longRegs[i], sf.longRegs[j]).toArray());
}

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

@DataProvider(name = "generations")
public Object[][] generations() {
  return LongStream.rangeClosed(1, 10)
    .mapToObj(i -> new Object[]{i})
    .toArray(Object[][]::new);
}

代码示例来源：origin: gofore/aws-training

@Override
public Stream<String> findPageUrls() throws Exception {
  Document document = Jsoup.connect(getPageUrl(1))
      .userAgent(USER_AGENT)
      .get();
  long results = getResults(document.select("#resultStats").text());
  long pages = results / IMAGES_PER_PAGE;
  long range = Math.min(pages, limit.orElse(Long.MAX_VALUE));
  return LongStream.rangeClosed(1, range).mapToObj(this::getPageUrl);
}

代码示例来源：origin: org.seaborne.rdf-delta/rdf-delta-server-local

private Stream<RDFPatch> range$(Version startVersion, Version finishVersion) {
  return
    LongStream
      .rangeClosed(startVersion.value(), finishVersion.value())
      .mapToObj(v->fetch(fileStore, v));
}

代码示例来源：origin: org.seaborne.rdf-delta/rdf-delta-server-local

@Override
public Stream<RDFPatch> range(Id start, Id finish) {
  Version startVersion = idToVersion.get(start);
  Version finishVersion = idToVersion.get(finish);
  if ( startVersion == null ) {}
  if ( finishVersion == null ) {}
  // Isolation not necessary. Patch files are immutable once written.
  return
    LongStream
      .rangeClosed(startVersion.value(), finishVersion.value())
      .mapToObj(v->fetch(fileStore, v));
}