Method run

src/main/java/com/oltpbenchmark/api/Worker.java:186–361

()

  }

  @Override
  public final void run() {
    Thread t = Thread.currentThread();
    t.setName(this.toString());

    // In case of reuse reset the measurements
    latencies = new LatencyRecord(workloadState.getTestStartNs());

    // Invoke setup session
    try {
      this.setupSession();
    } catch (Throwable ex) {
      throw new RuntimeException("Unexpected error when setting up the session " + this, ex);
    }

    // Invoke initialize callback
    try {
      this.initialize();
    } catch (Throwable ex) {
      throw new RuntimeException("Unexpected error when initializing " + this, ex);
    }

    // wait for start
    workloadState.blockForStart();

    while (true) {

      // PART 1: Init and check if done

      State preState = workloadState.getGlobalState();

      // Do nothing
      if (preState == State.DONE) {
        if (!seenDone) {
          // This is the first time we have observed that the
          // test is done notify the global test state, then
          // continue applying load
          seenDone = true;
          workloadState.signalDone();
          break;
        }
      }

      // PART 2: Wait for work

      // Sleep if there's nothing to do.
      workloadState.stayAwake();

      Phase prePhase = workloadState.getCurrentPhase();
      if (prePhase == null) {
        continue;
      }

      // Grab some work and update the state, in case it changed while we
      // waited.

      SubmittedProcedure pieceOfWork = workloadState.fetchWork();