Method AcquireThreadToken

be/src/runtime/thread-resource-mgr.h:124–128

Acquire a thread for the pool. This will always succeed; the pool will go over the quota if needed. Pools should use this API to reserve threads they need in order to make progress.

  /// quota if needed. Pools should use this API to reserve threads they need in order to
  /// make progress.
  void AcquireThreadToken() {
    int64_t num_threads = num_threads_.Add(1);
    int64_t num_required = num_threads & REQUIRED_MASK;
    DCHECK_LE(num_required, max_required_threads_);
  }

  /// Try to acquire a thread for this pool. If the pool is at the quota, this will
  /// return false and the pool should not run. Pools should use this API for resources