keycloak
公開メンバ関数 | 非公開変数類 | 静的非公開変数類 | 全メンバ一覧
org.keycloak.models.sessions.infinispan.util.FuturesHelper クラス
org.keycloak.models.sessions.infinispan.util.FuturesHelper 連携図
Collaboration graph

公開メンバ関数

void addTask (Future future)
 
void waitForAllToFinish ()
 
int size ()
 

非公開変数類

final Queue< Future > futures = new LinkedList<>()
 

静的非公開変数類

static final Logger log = Logger.getLogger(FuturesHelper.class)
 

詳解

Not thread-safe. Assumes tasks are added from single thread.

著者
Marek Posolda

関数詳解

◆ addTask()

void org.keycloak.models.sessions.infinispan.util.FuturesHelper.addTask ( Future  future)
inline
39  {
40  this.futures.add(future);
41  }
final Queue< Future > futures
Definition: FuturesHelper.java:36

◆ size()

int org.keycloak.models.sessions.infinispan.util.FuturesHelper.size ( )
inline
55  {
56  return futures.size();
57  }
final Queue< Future > futures
Definition: FuturesHelper.java:36

◆ waitForAllToFinish()

void org.keycloak.models.sessions.infinispan.util.FuturesHelper.waitForAllToFinish ( )
inline
44  {
45  for (Future future : futures) {
46  try {
47  future.get();
48  } catch (ExecutionException | InterruptedException ee) {
49  log.error("Exception when waiting for future", ee); // TODO Possibly some good mechanism to avoid swamp log with many same exceptions?
50  }
51  }
52  }
final Queue< Future > futures
Definition: FuturesHelper.java:36
static final Logger log
Definition: FuturesHelper.java:34

メンバ詳解

◆ futures

final Queue<Future> org.keycloak.models.sessions.infinispan.util.FuturesHelper.futures = new LinkedList<>()
private

◆ log

final Logger org.keycloak.models.sessions.infinispan.util.FuturesHelper.log = Logger.getLogger(FuturesHelper.class)
staticprivate

このクラス詳解は次のファイルから抽出されました: