java.util.concurrent.ForkJoinPool.hasQueuedSubmissions()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(2.0k)|赞(0)|评价(0)|浏览(140)

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

ForkJoinPool.hasQueuedSubmissions介绍

[英]Returns true if there are any tasks submitted to this pool that have not yet begun executing.
[中]如果有任何提交到此池的任务尚未开始执行,则返回true。

代码示例

代码示例来源:origin: kilim/kilim

public boolean isEmptyish() {
  return ! pool.hasQueuedSubmissions();
}

代码示例来源:origin: robovm/robovm

hasQueuedSubmissions())
return false;

代码示例来源:origin: de.unijena.bioinf/jjobs-core

protected synchronized void tryFixedThreadJobSubmission() { //queue, executor, as well as the job operations are finished thread save. so no need for sync here
  JJob job;
  while (!executor.hasQueuedSubmissions() && (job = jobsReadyToSubmit.poll()) != null)
    job.setFuture(executor.submit(job));
}

代码示例来源:origin: com.oracle.substratevm/pointsto

public void init(Timing newTiming) {
  assert isSequential() || !executorService.hasQueuedSubmissions();
  assert Thread.currentThread() == mainThread;
  timing = newTiming;
  setState(State.BEFORE_START);
  postedOperations.reset();
  completedOperations.reset();
  postedBeforeStart.clear();
  vmConfig = bb.getHostVM().getConfiguration();
}

代码示例来源:origin: com.oracle.substratevm/pointsto

public void shutdown() {
  assert isSequential() || !executorService.hasQueuedSubmissions() : "There should be no queued submissions on shutdown.";
  assert completedOperations.sum() == postedOperations.sum() : "Posted operations must match completed operations";
  setState(State.UNUSED);
}

代码示例来源:origin: com.gluonhq/robovm-rt

hasQueuedSubmissions())
return false;

代码示例来源:origin: FlexoVM/flexovm

hasQueuedSubmissions())
return false;

代码示例来源:origin: ibinti/bugvm

hasQueuedSubmissions())
return false;

代码示例来源:origin: MobiVM/robovm

hasQueuedSubmissions())
return false;

代码示例来源:origin: com.bugvm/bugvm-rt

hasQueuedSubmissions())
return false;

代码示例来源:origin: com.mobidevelop.robovm/robovm-rt

hasQueuedSubmissions())
return false;

相关文章

ForkJoinPool类方法