Package org.apache.druid.concurrent

Class Threads

java.lang.Object

org.apache.druid.concurrent.Threads

public final class Threads
extends Object

Constructor Summary

Constructors

Constructor	Description
Threads()

Method Summary

Modifier and Type	Method	Description
static void	sleepFor(long sleepTime, TimeUnit unit)	Equivalent of Thread.sleep(long) with arguments and semantics of timed wait methods in classes from java.util.concurrent (like Semaphore.tryAcquire(long, TimeUnit), Lock.tryLock(long, TimeUnit), etc.): if the sleepTime argument is negative or zero, the method returns immediately.
static AutoCloseable	withThreadName(String name)	Temporarily renames the thread.

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

sleepFor

public static void sleepFor(long sleepTime,
 TimeUnit unit)
                     throws InterruptedException

Equivalent of Thread.sleep(long) with arguments and semantics of timed wait methods in classes from java.util.concurrent (like Semaphore.tryAcquire(long, TimeUnit), Lock.tryLock(long, TimeUnit), etc.): if the sleepTime argument is negative or zero, the method returns immediately. Thread.sleep(long), on the contrary, throws an IllegalArgumentException if the argument is negative and attempts to unschedule the thread if the argument is zero.

Throws:

InterruptedException - if the current thread is interrupted when this method is called or during sleeping.

withThreadName

public static AutoCloseable withThreadName(String name)

Temporarily renames the thread. Preferred usage should be via try-with-resources clauses.

Returns:

a AutoCloseable to rename the thread back to its original name.