parked-scope-inl.h

Go to the documentation of this file.

// Copyright 2023 the V8 project authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
 
#ifndef V8_HEAP_PARKED_SCOPE_INL_H_
#define V8_HEAP_PARKED_SCOPE_INL_H_
 
#include "src/heap/parked-scope.h"
// Include the non-inl header before the rest of the headers.
 
#include "src/base/platform/condition-variable.h"
#include "src/base/platform/mutex.h"
#include "src/base/platform/semaphore.h"
#include "src/execution/local-isolate.h"
#include "src/heap/local-heap-inl.h"
 
namespace v8 {
namespace internal {
 
V8_INLINE ParkedMutexGuard::ParkedMutexGuard(LocalIsolate* local_isolate,
                                             base::Mutex* mutex)
    : ParkedMutexGuard(local_isolate->heap(), mutex) {}
 
V8_INLINE ParkedMutexGuard::ParkedMutexGuard(LocalHeap* local_heap,
                                             base::Mutex* mutex)
    : mutex_(mutex) {
  DCHECK(AllowGarbageCollection::IsAllowed());
  if (!mutex_->TryLock()) {
    local_heap->ExecuteWhileParked([this]() { mutex_->Lock(); });
  }
}
 
V8_INLINE ParkedRecursiveMutexGuard::ParkedRecursiveMutexGuard(
    LocalIsolate* local_isolate, base::RecursiveMutex* mutex)
    : ParkedRecursiveMutexGuard(local_isolate->heap(), mutex) {}
 
V8_INLINE ParkedRecursiveMutexGuard::ParkedRecursiveMutexGuard(
    LocalHeap* local_heap, base::RecursiveMutex* mutex)
    : mutex_(mutex) {
  DCHECK(AllowGarbageCollection::IsAllowed());
  if (!mutex_->TryLock()) {
    local_heap->ExecuteWhileParked([this]() { mutex_->Lock(); });
  }
}
 
V8_INLINE ParkedMutexGuardIf::ParkedMutexGuardIf(LocalIsolate* local_isolate,
                                                 base::Mutex* mutex,
                                                 bool enable_mutex)
    : ParkedMutexGuardIf(local_isolate -> heap(), mutex, enable_mutex) {}
V8_INLINE ParkedMutexGuardIf::ParkedMutexGuardIf(LocalHeap* local_heap,
                                                 base::Mutex* mutex,
                                                 bool enable_mutex) {
  DCHECK(AllowGarbageCollection::IsAllowed());
  if (!enable_mutex) return;
  mutex_ = mutex;
 
  if (!mutex_->TryLock()) {
    local_heap->ExecuteWhileParked([this]() { mutex_->Lock(); });
  }
}
 
V8_INLINE void ParkingConditionVariable::ParkedWait(LocalIsolate* local_isolate,
                                                    base::Mutex* mutex) {
  ParkedWait(local_isolate->heap(), mutex);
}
 
V8_INLINE void ParkingConditionVariable::ParkedWait(LocalHeap* local_heap,
                                                    base::Mutex* mutex) {
  local_heap->ExecuteWhileParked(
      [this, mutex](const ParkedScope& parked) { ParkedWait(parked, mutex); });
}
 
V8_INLINE bool ParkingConditionVariable::ParkedWaitFor(
    LocalIsolate* local_isolate, base::Mutex* mutex,
    const base::TimeDelta& rel_time) {
  return ParkedWaitFor(local_isolate->heap(), mutex, rel_time);
}
 
V8_INLINE bool ParkingConditionVariable::ParkedWaitFor(
    LocalHeap* local_heap, base::Mutex* mutex,
    const base::TimeDelta& rel_time) {
  bool result;
  local_heap->ExecuteWhileParked(
      [this, mutex, rel_time, &result](const ParkedScope& parked) {
        result = ParkedWaitFor(parked, mutex, rel_time);
      });
  return result;
}
 
V8_INLINE void ParkingSemaphore::ParkedWait(LocalIsolate* local_isolate) {
  ParkedWait(local_isolate->heap());
}
 
V8_INLINE void ParkingSemaphore::ParkedWait(LocalHeap* local_heap) {
  local_heap->ExecuteWhileParked(
      [this](const ParkedScope& parked) { ParkedWait(parked); });
}
 
V8_INLINE bool ParkingSemaphore::ParkedWaitFor(
    LocalIsolate* local_isolate, const base::TimeDelta& rel_time) {
  return ParkedWaitFor(local_isolate->heap(), rel_time);
}
 
V8_INLINE bool ParkingSemaphore::ParkedWaitFor(
    LocalHeap* local_heap, const base::TimeDelta& rel_time) {
  bool result;
  local_heap->ExecuteWhileParked(
      [this, rel_time, &result](const ParkedScope& parked) {
        result = ParkedWaitFor(parked, rel_time);
      });
  return result;
}
 
V8_INLINE void ParkingThread::ParkedJoin(LocalIsolate* local_isolate) {
  ParkedJoin(local_isolate->heap());
}
 
V8_INLINE void ParkingThread::ParkedJoin(LocalHeap* local_heap) {
  local_heap->ExecuteWhileParked(
      [this](const ParkedScope& parked) { ParkedJoin(parked); });
}
 
template <typename ThreadCollection>
// static
V8_INLINE void ParkingThread::ParkedJoinAll(LocalIsolate* local_isolate,
                                            const ThreadCollection& threads) {
  ParkedJoinAll(local_isolate->heap(), threads);
}
 
template <typename ThreadCollection>
// static
V8_INLINE void ParkingThread::ParkedJoinAll(LocalHeap* local_heap,
                                            const ThreadCollection& threads) {
  local_heap->ExecuteWhileParked([&threads](const ParkedScope& parked) {
    ParkedJoinAll(parked, threads);
  });
}
 
}  // namespace internal
}  // namespace v8
 
#endif  // V8_HEAP_PARKED_SCOPE_INL_H_