Package arc.util

Class Threads

java.lang.Object

arc.util.Threads

public class Threads
extends Object

Utilities for threaded programming.

Constructor Summary

Constructors

Constructor	Description
Threads()

Method Summary

Modifier and Type	Method	Description
static void	await(ExecutorService exec)	Shuts down the executor and waits for its termination indefinitely.
static <T> T	await(Future<T> future)
static void	awaitAll(Seq<Future<?>> futures)
static ExecutorService	boundedExecutor(String name, int max)
static Thread	daemon(Runnable runnable)	Starts a new daemon thread.
static Thread	daemon(String name, Runnable runnable)	Starts a new daemon thread.
static ExecutorService	executor()
static ExecutorService	executor(int threads)
static ExecutorService	executor(String name)
static ExecutorService	executor(String name, int threads)
static <T> ThreadLocal<T>	local(Prov<T> prov)
static void	sleep(long ms)
static void	sleep(long ms, int ns)
static Thread	thread(Runnable runnable)	Starts a new non-daemon thread.
static Thread	thread(String name, Runnable runnable)	Starts a new non-daemon thread.
static void	throwAppException(Throwable t)	Throws an exception in the main game thread.
static ExecutorService	unboundedExecutor()
static ExecutorService	unboundedExecutor(String name)
static ExecutorService	unboundedExecutor(String name, int min)

Methods inherited from class java.lang.Object

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

Constructor Details

Threads

public Threads()

Method Details

local

public static <T> ThreadLocal<T> local(Prov<T> prov)

await

public static <T> T await(Future<T> future)

awaitAll

public static void awaitAll(Seq<Future<?>> futures)

executor

public static ExecutorService executor(@Nullable
 String name,
 int threads)

Returns:

an executor with a fixed number of threads which do not expire

executor

public static ExecutorService executor(int threads)

Returns:

an executor with a fixed number of threads which do not expire

executor

public static ExecutorService executor(@Nullable
 String name)

See Also:

• executor(String, int)

executor

public static ExecutorService executor()

See Also:

• executor(String, int)

unboundedExecutor

public static ExecutorService unboundedExecutor(@Nullable
 String name,
 int min)

Parameters:

min - the number of threads to keep alive at all times after they are first started

Returns:

an executor with no max thread count. threads expire after 1 minute of inactivity

unboundedExecutor

public static ExecutorService unboundedExecutor(@Nullable
 String name)

See Also:

• unboundedExecutor(String, int)

unboundedExecutor

public static ExecutorService unboundedExecutor()

See Also:

• unboundedExecutor(String, int)

boundedExecutor

public static ExecutorService boundedExecutor(@Nullable
 String name,
 int max)

Parameters:

max - maximum number of threads to create

Returns:

an executor with a max thread count. threads expire after 1 minute of inactivity

await

public static void await(ExecutorService exec)

Shuts down the executor and waits for its termination indefinitely.

sleep

public static void sleep(long ms)

sleep

public static void sleep(long ms,
 int ns)

throwAppException

public static void throwAppException(Throwable t)

Throws an exception in the main game thread.

thread

public static Thread thread(Runnable runnable)

Starts a new non-daemon thread.

thread

public static Thread thread(@Nullable
 String name,
 Runnable runnable)

Starts a new non-daemon thread.

daemon

public static Thread daemon(Runnable runnable)

Starts a new daemon thread.

daemon

public static Thread daemon(@Nullable
 String name,
 Runnable runnable)

Starts a new daemon thread.