cloud.orbit.actors.runtime

Class InternalUtils

java.lang.Object

cloud.orbit.actors.runtime.InternalUtils

public class InternalUtils
extends Object

Internal utility class. DO NOT use it outside the orbit project. This class is not part of the public orbit api and its api may change from version to version.

Constructor Summary

Constructors

Constructor and Description
InternalUtils()

Method Summary

Modifier and Type	Method and Description
static <T> Class<T>	classForName(String className)
static <T> Class<T>	classForName(String className, boolean ignoreException)
static String	hexDump(int columns, byte[] raw, int offset, int length)
static void	linkFutures(CompletableFuture source, CompletableFuture target)
static void	linkFuturesOnError(CompletableFuture source, CompletableFuture target)
static <K,V> V	putIfAbsentAndGet(ConcurrentMap<K,V> map, K key, V newValue) If the specified key is not already associated with a value, associate it with the given value.
static <R> Task<R>	safeInvoke(Supplier<Task<R>> supplier)
static void	sleep(long millis) Invokes Thread.sleep().

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalUtils

public InternalUtils()

Method Detail

classForName

public static <T> Class<T> classForName(String className)

classForName

public static <T> Class<T> classForName(String className,
                                        boolean ignoreException)

sleep

public static void sleep(long millis)

Invokes Thread.sleep(). If sleep() is interrupted, interrupted-state will be asserted again, in order to support cancellation. For explanation of cancellation in this context, see: http://g.oswego.edu/dl/cpj/cancel.html

Parameters:

millis -

linkFutures

public static void linkFutures(CompletableFuture source,
                               CompletableFuture target)

linkFuturesOnError

public static void linkFuturesOnError(CompletableFuture source,
                                      CompletableFuture target)

putIfAbsentAndGet

public static <K,V> V putIfAbsentAndGet(ConcurrentMap<K,V> map,
                                        K key,
                                        V newValue)

If the specified key is not already associated with a value, associate it with the given value. And return the final value stored in the map. This is equivalent to

 
 if (!map.containsKey(key)) {
   map.put(key, value);
   return value;
 } else {
   return map.get(key);
 }

except that the action is performed atomically.

hexDump

public static String hexDump(int columns,
                             byte[] raw,
                             int offset,
                             int length)

safeInvoke

public static <R> Task<R> safeInvoke(Supplier<Task<R>> supplier)