Method testBank

src/test/java/io/dgraph/BankTest.java:122–141

()

  }

  @Test
  public void testBank() throws Exception {
    createAccounts();
    logger.debug(Arrays.toString(uids.toArray()));

    ExecutorService totalEx = Executors.newSingleThreadExecutor();
    totalEx.execute(this::runTotalInLoop);
    totalEx.shutdown();

    ExecutorService txnEx = Executors.newCachedThreadPool();
    for (int i = 0; i < 10; i++) {
      txnEx.execute(this::txnLoop);
    }
    txnEx.shutdown();

    if (!txnEx.awaitTermination(5, TimeUnit.MINUTES)) {
      logger.debug("Timeout elapsed");
    }
    totalEx.awaitTermination(5, TimeUnit.SECONDS);
  }

  static class Account {
    int bal;