Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- int _countDown= 6;
- object _lock;
- void ReadyMessageReceivedForTheFirstTimeFromAConnection() {
- lock(_lock) {
- --_countDown; //
- if (_countDown==0) Start();
- }
- }
- (let [latch (CountDownLatch. 6)]
- (on-receive-message this (fn [_] (.countDown latch)))
- (.await latch)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement