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

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

ForkJoinPool.isTerminated介绍

[英]Returns true if all tasks have completed following shut down.
[中]如果关闭后所有任务都已完成，则返回true。

代码示例

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

throws InterruptedException {
long nanos = unit.toNanos(timeout);
if (isTerminated())
return true;
if (nanos <= 0L)
synchronized (this) {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0L)

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

throws InterruptedException {
long nanos = unit.toNanos(timeout);
if (isTerminated())
return true;
if (nanos <= 0L)
synchronized (this) {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0L)

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

throws InterruptedException {
long nanos = unit.toNanos(timeout);
if (isTerminated())
return true;
if (nanos <= 0L)
synchronized (this) {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0L)

代码示例来源：origin: org.apidesign.bck2brwsr/emul

/**
* Blocks until all tasks have completed execution after a shutdown
* request, or the timeout occurs, or the current thread is
* interrupted, whichever happens first.
*
* @param timeout the maximum time to wait
* @param unit the time unit of the timeout argument
* @return {@code true} if this executor terminated and
* {@code false} if the timeout elapsed before termination
* @throws InterruptedException if interrupted while waiting
*/
public boolean awaitTermination(long timeout, TimeUnit unit)
throws InterruptedException {
long nanos = unit.toNanos(timeout);
final ReentrantLock lock = this.submissionLock;
lock.lock();
try {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0)
return false;
nanos = termination.awaitNanos(nanos);
}
} finally {
lock.unlock();
}
}

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

throws InterruptedException {
long nanos = unit.toNanos(timeout);
if (isTerminated())
return true;
if (nanos <= 0L)
synchronized (this) {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0L)

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

throws InterruptedException {
long nanos = unit.toNanos(timeout);
if (isTerminated())
return true;
if (nanos <= 0L)
synchronized (this) {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0L)

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

throws InterruptedException {
long nanos = unit.toNanos(timeout);
if (isTerminated())
return true;
if (nanos <= 0L)
synchronized (this) {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0L)

代码示例来源：origin: jtulach/bck2brwsr

/**
* Blocks until all tasks have completed execution after a shutdown
* request, or the timeout occurs, or the current thread is
* interrupted, whichever happens first.
*
* @param timeout the maximum time to wait
* @param unit the time unit of the timeout argument
* @return {@code true} if this executor terminated and
* {@code false} if the timeout elapsed before termination
* @throws InterruptedException if interrupted while waiting
*/
public boolean awaitTermination(long timeout, TimeUnit unit)
throws InterruptedException {
long nanos = unit.toNanos(timeout);
final ReentrantLock lock = this.submissionLock;
lock.lock();
try {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0)
return false;
nanos = termination.awaitNanos(nanos);
}
} finally {
lock.unlock();
}
}

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

throws InterruptedException {
long nanos = unit.toNanos(timeout);
if (isTerminated())
return true;
if (nanos <= 0L)
synchronized (this) {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0L)

代码示例来源：origin: org.codehaus.jsr166-mirror/jsr166

/**
* Blocks until all tasks have completed execution after a shutdown
* request, or the timeout occurs, or the current thread is
* interrupted, whichever happens first.
*
* @param timeout the maximum time to wait
* @param unit the time unit of the timeout argument
* @return {@code true} if this executor terminated and
* {@code false} if the timeout elapsed before termination
* @throws InterruptedException if interrupted while waiting
*/
public boolean awaitTermination(long timeout, TimeUnit unit)
throws InterruptedException {
long nanos = unit.toNanos(timeout);
final ReentrantLock lock = this.submissionLock;
lock.lock();
try {
for (;;) {
if (isTerminated())
return true;
if (nanos <= 0)
return false;
nanos = termination.awaitNanos(nanos);
}
} finally {
lock.unlock();
}
}

代码示例来源：origin: co.paralleluniverse/quasar-core

@Override
public ForkJoinPoolMonitor.Status getStatus() {
final ForkJoinPool fjPool = fjPool();
if (fjPool.isTerminated()) // Returns true if all tasks have completed following shut down.
return ForkJoinPoolMonitor.Status.TERMINATED;
if (fjPool.isTerminating()) // Returns true if the process of termination has commenced but not yet completed.
return ForkJoinPoolMonitor.Status.TERMINATING;
if (fjPool.isShutdown()) // Returns true if this pool has been shut down.
return ForkJoinPoolMonitor.Status.SHUTDOWN;
if (fjPool.isQuiescent()) // Returns true if all worker threads are currently idle.
return ForkJoinPoolMonitor.Status.QUIESCENT;
return ForkJoinPoolMonitor.Status.ACTIVE;
}

代码示例来源：origin: co.paralleluniverse/quasar-core

@Override
public Status getValue() {
final ForkJoinPool fjPool = fjPool();
if (fjPool.isTerminated()) // Returns true if all tasks have completed following shut down.
return ForkJoinPoolMonitor.Status.TERMINATED;
if (fjPool.isTerminating()) // Returns true if the process of termination has commenced but not yet completed.
return ForkJoinPoolMonitor.Status.TERMINATING;
if (fjPool.isShutdown()) // Returns true if this pool has been shut down.
return ForkJoinPoolMonitor.Status.SHUTDOWN;
if (fjPool.isQuiescent()) // Returns true if all worker threads are currently idle.
return ForkJoinPoolMonitor.Status.QUIESCENT;
return ForkJoinPoolMonitor.Status.ACTIVE;
}
});