public class ConcurrencyTools
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static java.lang.Object |
evaluateFuture(java.util.concurrent.Future future,
org.apache.log4j.Logger logger,
boolean doThrow,
java.lang.String text)
Blocks until all passed Futures have completed.
|
static java.lang.Object |
evaluateFuture(java.util.concurrent.Future future,
org.apache.log4j.Logger logger,
boolean doThrow,
java.lang.String progressStart,
java.lang.String progress,
java.lang.String progressFinish)
Blocks until the passed Future has completed.
|
static java.util.List<java.lang.Object> |
evaluateFutures(java.util.List<java.util.concurrent.Future> futures,
org.apache.log4j.Logger logger,
boolean doThrow,
java.lang.String text)
Blocks until all passed Futures have completed.
|
static java.util.List<java.lang.Object> |
evaluateFutures(java.util.List<java.util.concurrent.Future> futures,
org.apache.log4j.Logger logger,
boolean doThrow,
java.lang.String progressStart,
java.lang.String progress,
java.lang.String progressFinish)
Blocks until all passed Futures have completed.
|
static int |
getReasonableParallelity()
Returns the number of parallel jobs that the current processors
should be able to handle without starving everything else (assuming
we are more or less the only one doing parallel work, thus this is
an idealized number).
|
public static final int getReasonableParallelity()
public static final java.lang.Object evaluateFuture(java.util.concurrent.Future future, org.apache.log4j.Logger logger, boolean doThrow, java.lang.String progressStart, java.lang.String progress, java.lang.String progressFinish)
public static final java.lang.Object evaluateFuture(java.util.concurrent.Future future, org.apache.log4j.Logger logger, boolean doThrow, java.lang.String text)
public static final java.util.List<java.lang.Object> evaluateFutures(java.util.List<java.util.concurrent.Future> futures, org.apache.log4j.Logger logger, boolean doThrow, java.lang.String progressStart, java.lang.String progress, java.lang.String progressFinish)
public static final java.util.List<java.lang.Object> evaluateFutures(java.util.List<java.util.concurrent.Future> futures, org.apache.log4j.Logger logger, boolean doThrow, java.lang.String text)
Copyright © 2000-2024 OAshi S.à r.l. All Rights Reserved.