de.unkrig.commons.lang

Class ThreadUtil

java.lang.Object

de.unkrig.commons.lang.ThreadUtil

public final class ThreadUtil
extends Object

Various java.lang.Thread-related utility methods.

Field Summary

Fields

Modifier and Type	Field and Description
static ThreadFactory	DAEMON_THREAD_FACTORY Produces daemon threads; handy for "new ScheduledThreadPoolExecutor{@code (... , ThreadFactory,

Method Summary

Modifier and Type	Method and Description
static <EX extends Throwable> void	parallel(Iterable<? extends RunnableWhichThrows<EX>> runnables)
static <EX extends Throwable> void	parallel(Iterable<? extends RunnableWhichThrows<EX>> runnables, Iterable<Stoppable> stoppables)
static void	parallel(Runnable[] runnables, Iterable<Stoppable> stoppables) Invokes the run method of all runnables in parallel threads (including the current thread).
static <EX extends Throwable> void	parallel(RunnableWhichThrows<EX> runnable1, RunnableWhichThrows<EX> runnable2, Stoppable stoppable) Executes the two runnables in parallel before it returns.
static Stoppable	runInBackground(Runnable runnable, String threadName) Execute the given runnable in a background thread
static <EX extends Throwable> Stoppable	runInBackground(RunnableWhichThrows<EX> runnable, String threadName)
static <R extends RunnableWhichThrows<EX>,EX extends Throwable> void	runInForeground(Iterable<R> runnables) Runs all but the last of runnables in the background, and the last of runnables in the foreground.
static <EX extends Throwable> void	runInForeground(RunnableWhichThrows<EX> runnable) Executes the given runnable.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DAEMON_THREAD_FACTORY

public static final ThreadFactory DAEMON_THREAD_FACTORY

Produces daemon threads; handy for "new ScheduledThreadPoolExecutor(... , ThreadFactory, ...)", because with the default ThreadFactory the JVM won't terminate when it shuts down orderly (i.e. "main()" returns or "System.exit()" is invoked).

Method Detail

runInBackground

public static Stoppable runInBackground(Runnable runnable,
                                        @Nullable
                                        String threadName)

Execute the given runnable in a background thread

Returns:

The background runnable can be interrupted through this object

runInBackground

public static <EX extends Throwable> Stoppable runInBackground(RunnableWhichThrows<EX> runnable,
                                                               @Nullable
                                                               String threadName)

See Also:

runInBackground(Runnable, String)

runInForeground

public static <EX extends Throwable> void runInForeground(RunnableWhichThrows<EX> runnable)
                                                   throws EX extends Throwable

Executes the given runnable.

Throws:

EX extends Throwable

parallel

public static <EX extends Throwable> void parallel(RunnableWhichThrows<EX> runnable1,
                                                   RunnableWhichThrows<EX> runnable2,
                                                   Stoppable stoppable)
                                            throws EX extends Throwable

Executes the two runnables in parallel before it returns.

Throws:

EX extends Throwable

parallel

public static <EX extends Throwable> void parallel(Iterable<? extends RunnableWhichThrows<EX>> runnables)
                                            throws EX extends Throwable

Throws:

EX extends Throwable

See Also:

parallel(Runnable[], Iterable)

parallel

public static <EX extends Throwable> void parallel(Iterable<? extends RunnableWhichThrows<EX>> runnables,
                                                   Iterable<Stoppable> stoppables)
                                            throws EX extends Throwable

Throws:

EX extends Throwable

See Also:

parallel(Runnable[], Iterable)

parallel

public static void parallel(Runnable[] runnables,
                            Iterable<Stoppable> stoppables)

Invokes the run method of all runnables in parallel threads (including the current thread). When the first of these invocations returns, then all threads are interrupted (which awakes them from blocking I/O), and also on all stoppables Stoppable.stop() is called. When all the threads have been joined, this method returns.

runInForeground

public static <R extends RunnableWhichThrows<EX>,EX extends Throwable> void runInForeground(Iterable<R> runnables)
                                                                                     throws EX extends Throwable

Runs all but the last of runnables in the background, and the last of runnables in the foreground.

Throws:

EX extends Throwable