mutex<R> method

  1. @visibleForTesting
  2. @protected
FutureOr<R?> mutex<R>(
  1. Object tag,
  2. FutureOr<R> action()
)
inherited

mutex 互斥锁 (Exhaust): 立即执行，执行期间的触发直接丢弃。

Implementation

@visibleForTesting
@protected
FutureOr<R?> mutex<R>(Object tag, FutureOr<R> Function() action) {
  if (isMutexLocked(tag)) {
    logF('mutex[$tag] SKIPPED');
  } else {
    logF('mutex[$tag] TRIGGERED');
  }
  return _slowly.mutex(tag, action);
}