Package net.jodah.concurrentunit

Examples of net.jodah.concurrentunit.Waiter.resume()

133
134
135
136
137
138
139
140
141
142
143
    new Thread(new Runnable() {
      @Override
      public void run() {
        try {
          circuit.await();
          waiter.resume();
        } catch (InterruptedException e) {
        }
      }
    }).start();
View Full Code Here
241
242
243
244
245
246
247
248
249
250
251
    for (int i = 0; i < 2; i++)
      runInThread(new Runnable() {
        public void run() {
          try {
            performInvocation();
            waiter.resume();
          } catch (Throwable t) {
            waiter.fail(t);
          }
        }
      });
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
  protected void startCluster(Set<Copycat> contexts) throws Throwable {
    Waiter waiter = new Waiter();
    for (Copycat context : contexts) {
      context.start().whenComplete((result, error) -> {
        waiter.assertNull(error);
        waiter.resume();
      });
    }

    waiter.await(10000, contexts.size());
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.