public void run()

in alpha/alpha-benchmark/src/main/java/org/apache/servicecomb/pack/alpha/benchmark/SagaEventBenchmark.java [158:188]

31 lines of code
5 McCabe index (conditional complexity)


    public void run() {
      try {
        begin.await();
        for (int i = 0; i < requests; i++) {
          metrics.completeRequestsIncrement();
          long s = System.currentTimeMillis();
          final String globalTxId = id_prefix + "-" + i;
          final String localTxId_1 = UUID.randomUUID().toString();
          final String localTxId_2 = UUID.randomUUID().toString();
          final String localTxId_3 = UUID.randomUUID().toString();
          try {
            sagaSuccessfulEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream()
                .forEach(event -> {
                  if(LOG.isDebugEnabled()){
                    LOG.debug(event.toString());
                  }
                  sender.send(event);
                });
          } catch (Throwable e) {
            metrics.failedRequestsIncrement();
          } finally {
            long e = System.currentTimeMillis();
            metrics.addTransactionTime(e - s);
          }
        }
        end.countDown();
      } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        LOG.error(e.getMessage(), e);
      }
    }