// Copyright 2018 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_THREAD_ID_H_ #define V8_THREAD_ID_H_ #include "src/base/atomicops.h" namespace v8 { namespace internal { // Platform-independent, reliable thread identifier. class ThreadId { public: // Creates an invalid ThreadId. ThreadId() { base::Relaxed_Store(&id_, kInvalidId); } ThreadId& operator=(const ThreadId& other) { base::Relaxed_Store(&id_, base::Relaxed_Load(&other.id_)); return *this; } bool operator==(const ThreadId& other) const { return Equals(other); } // Returns ThreadId for current thread if it exists or invalid id. static ThreadId TryGetCurrent(); // Returns ThreadId for current thread. static ThreadId Current() { return ThreadId(GetCurrentThreadId()); } // Returns invalid ThreadId (guaranteed not to be equal to any thread). static ThreadId Invalid() { return ThreadId(kInvalidId); } // Compares ThreadIds for equality. V8_INLINE bool Equals(const ThreadId& other) const { return base::Relaxed_Load(&id_) == base::Relaxed_Load(&other.id_); } // Checks whether this ThreadId refers to any thread. V8_INLINE bool IsValid() const { return base::Relaxed_Load(&id_) != kInvalidId; } // Converts ThreadId to an integer representation // (required for public API: V8::V8::GetCurrentThreadId). int ToInteger() const { return static_cast<int>(base::Relaxed_Load(&id_)); } // Converts ThreadId to an integer representation // (required for public API: V8::V8::TerminateExecution). static ThreadId FromInteger(int id) { return ThreadId(id); } private: static const int kInvalidId = -1; explicit ThreadId(int id) { base::Relaxed_Store(&id_, id); } static int AllocateThreadId() { int new_id = base::Relaxed_AtomicIncrement(&highest_thread_id_, 1); return new_id; } static int GetCurrentThreadId(); base::Atomic32 id_; static base::Atomic32 highest_thread_id_; }; } // namespace internal } // namespace v8 #endif // V8_THREAD_ID_H_