private void interrupt()

in omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/wrapper/TimeoutProbManager.java [73:85]

• 13 lines of code
• 5 McCabe index (conditional complexity)

  private void interrupt() {
    synchronized (this.interrupter) {
      for (TimeoutProb timeoutProb : this.timeoutProbs) {
        if (timeoutProb.getInterruptFailureException() == null) {
          if (timeoutProb.expired()) {
            if (timeoutProb.interrupted()) {
              this.timeoutProbs.remove(timeoutProb);
            }
          }
        }
      }
    }
  }