diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-10 14:57:25 +0200 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-10 14:57:25 +0200 |
commit | 18f9092fe0c52396dbc1d7978533ab1d8c61f76b (patch) | |
tree | cd189d87cf37c24fd3964b2c4b3f11e5bb3c16e8 /same/src/main | |
parent | 98e7ea2631ab1a4aef47792053422bb9a7921aa9 (diff) |
Add missing class RpcList.
Diffstat (limited to 'same/src/main')
-rw-r--r-- | same/src/main/java/com/orbekk/util/RpcList.java | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/same/src/main/java/com/orbekk/util/RpcList.java b/same/src/main/java/com/orbekk/util/RpcList.java new file mode 100644 index 0000000..10eecc1 --- /dev/null +++ b/same/src/main/java/com/orbekk/util/RpcList.java @@ -0,0 +1,21 @@ +package com.orbekk.util; + +import java.util.ArrayList; +import java.util.List; + +import com.orbekk.protobuf.Rpc; + +public class RpcList { + private List<Rpc> rpcs = new ArrayList<Rpc>(); + + public synchronized void add(Rpc rpc) { + rpcs.add(rpc); + } + + public synchronized void awaitAll() throws InterruptedException { + for (Rpc rpc : rpcs) { + rpc.await(); + } + rpcs.clear(); + } +} |