Woolpack API

woolpack.acquirable
クラス AcquirableUtils

java.lang.Object
  上位を拡張 woolpack.acquirable.AcquirableUtils

public final class AcquirableUtils
extends java.lang.Object

実行権制御のユーティリティです。 型推論で表記を簡略するためのスタティックメソッドを含みます。

作成者:
nakamura

フィールドの概要
static Acquirable<java.lang.RuntimeException> ANY
          無制限に実行権を与えるAcquirableです。
static Acquirable<java.lang.RuntimeException> INTERRUPT
          常に実行権を与えず、実行したスレッドに対しThread.interrupt()を実行するAcquirableです。
static Acquirable<java.lang.InterruptedException> INTERRUPTED_EXCEPTION
          常に実行権を与えず、 実行したスレッドに対しThread.interrupt()を実行し、 InterruptedExceptionを原因として持つ IllegalStateExceptionを投げるAcquirableです。
static Acquirable<java.lang.RuntimeException> NONE
          常に実行権を与えないAcquirableです。
 
メソッドの概要
static
<C,R,E extends java.lang.Exception>
AcquireFn<C,R,E>
acquire(Fn<? super C,? extends Acquirable<? extends E>,? extends E> acquireGetter, Fn<? super C,? extends R,? extends E> trueFn, Fn<? super C,? extends R,? extends E> falseFn)
           
static
<E extends java.lang.Exception>
AcquirableChain<E>
chain(java.util.List<? extends Acquirable<? extends E>> list)
           
static DoLock<java.lang.RuntimeException> doLock(java.util.concurrent.locks.Lock lock)
           
static DoSemaphore doSemaphore(java.util.concurrent.Semaphore semaphore)
           
static TryLock<java.lang.RuntimeException> tryLock(java.util.concurrent.locks.Lock lock)
           
static TrySemaphore<java.lang.RuntimeException> trySemaphore(java.util.concurrent.Semaphore semaphore)
           
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

ANY

public static final Acquirable<java.lang.RuntimeException> ANY
無制限に実行権を与えるAcquirableです。


NONE

public static final Acquirable<java.lang.RuntimeException> NONE
常に実行権を与えないAcquirableです。


INTERRUPT

public static final Acquirable<java.lang.RuntimeException> INTERRUPT
常に実行権を与えず、実行したスレッドに対しThread.interrupt()を実行するAcquirableです。


INTERRUPTED_EXCEPTION

public static final Acquirable<java.lang.InterruptedException> INTERRUPTED_EXCEPTION
常に実行権を与えず、 実行したスレッドに対しThread.interrupt()を実行し、 InterruptedExceptionを原因として持つ IllegalStateExceptionを投げるAcquirableです。

メソッドの詳細

acquire

public static <C,R,E extends java.lang.Exception> AcquireFn<C,R,E> acquire(Fn<? super C,? extends Acquirable<? extends E>,? extends E> acquireGetter,
                                                                           Fn<? super C,? extends R,? extends E> trueFn,
                                                                           Fn<? super C,? extends R,? extends E> falseFn)

doLock

public static DoLock<java.lang.RuntimeException> doLock(java.util.concurrent.locks.Lock lock)

doSemaphore

public static DoSemaphore doSemaphore(java.util.concurrent.Semaphore semaphore)

tryLock

public static TryLock<java.lang.RuntimeException> tryLock(java.util.concurrent.locks.Lock lock)

trySemaphore

public static TrySemaphore<java.lang.RuntimeException> trySemaphore(java.util.concurrent.Semaphore semaphore)

chain

public static <E extends java.lang.Exception> AcquirableChain<E> chain(java.util.List<? extends Acquirable<? extends E>> list)

Woolpack API

Copyright (C) 2006-2007 Takahiro Nakamura. All rights reserved.