< prev index next >

src/hotspot/share/runtime/thread.inline.hpp

Print this page
rev 47819 : imported patch 10.07.open.rebase_20171110.dcubed

*** 23,40 **** */ #ifndef SHARE_VM_RUNTIME_THREAD_INLINE_HPP #define SHARE_VM_RUNTIME_THREAD_INLINE_HPP - #define SHARE_VM_RUNTIME_THREAD_INLINE_HPP_SCOPE - #include "runtime/atomic.hpp" #include "runtime/os.inline.hpp" #include "runtime/thread.hpp" - #undef SHARE_VM_RUNTIME_THREAD_INLINE_HPP_SCOPE - inline void Thread::set_suspend_flag(SuspendFlags f) { assert(sizeof(jint) == sizeof(_suspend_flags), "size mismatch"); uint32_t flags; do { flags = _suspend_flags; --- 23,37 ---- */ #ifndef SHARE_VM_RUNTIME_THREAD_INLINE_HPP #define SHARE_VM_RUNTIME_THREAD_INLINE_HPP #include "runtime/atomic.hpp" #include "runtime/os.inline.hpp" #include "runtime/thread.hpp" + #include "runtime/threadSMR.hpp" inline void Thread::set_suspend_flag(SuspendFlags f) { assert(sizeof(jint) == sizeof(_suspend_flags), "size mismatch"); uint32_t flags; do { flags = _suspend_flags;
*** 87,96 **** --- 84,105 ---- } } return allocated_bytes; } + inline ThreadsList* Thread::cmpxchg_threads_hazard_ptr(ThreadsList* exchange_value, ThreadsList* compare_value) { + return (ThreadsList*)Atomic::cmpxchg(exchange_value, &_threads_hazard_ptr, compare_value); + } + + inline ThreadsList* Thread::get_threads_hazard_ptr() { + return (ThreadsList*)OrderAccess::load_acquire(&_threads_hazard_ptr); + } + + inline void Thread::set_threads_hazard_ptr(ThreadsList* new_list) { + OrderAccess::release_store_fence(&_threads_hazard_ptr, new_list); + } + inline void JavaThread::set_ext_suspended() { set_suspend_flag (_ext_suspended); } inline void JavaThread::clear_ext_suspended() { clear_suspend_flag(_ext_suspended);
*** 173,178 **** --- 182,272 ---- // the reading the handshake operation or the global state inline volatile void* JavaThread::get_polling_page() { return OrderAccess::load_acquire(polling_page_addr()); } + inline bool JavaThread::is_exiting() const { + // Use load-acquire so that setting of _terminated by + // JavaThread::exit() is seen more quickly. + TerminatedTypes l_terminated = (TerminatedTypes) + OrderAccess::load_acquire((volatile jint *) &_terminated); + return l_terminated == _thread_exiting || check_is_terminated(l_terminated); + } + + inline bool JavaThread::is_terminated() { + // Use load-acquire so that setting of _terminated by + // JavaThread::exit() is seen more quickly. + TerminatedTypes l_terminated = (TerminatedTypes) + OrderAccess::load_acquire((volatile jint *) &_terminated); + return check_is_terminated(_terminated); + } + + inline void JavaThread::set_terminated(TerminatedTypes t) { + // use release-store so the setting of _terminated is seen more quickly + OrderAccess::release_store((volatile jint *) &_terminated, (jint) t); + } + + // special for Threads::remove() which is static: + inline void JavaThread::set_terminated_value() { + // use release-store so the setting of _terminated is seen more quickly + OrderAccess::release_store((volatile jint *) &_terminated, (jint) _thread_terminated); + } + + template <class T> + inline void Threads::threads_do_smr(T *tc, Thread *self) { + ThreadsListHandle handle(self); + handle.threads_do(tc); + } + + inline ThreadsList* Threads::get_smr_java_thread_list() { + return (ThreadsList*)OrderAccess::load_acquire(&_smr_java_thread_list); + } + + inline ThreadsList* Threads::xchg_smr_java_thread_list(ThreadsList* new_list) { + return (ThreadsList*)Atomic::xchg(new_list, &_smr_java_thread_list); + } + + inline void Threads::inc_smr_deleted_thread_cnt() { + Atomic::inc(&_smr_deleted_thread_cnt); + } + + inline void Threads::update_smr_deleted_thread_time_max(jint new_value) { + while (true) { + jint cur_value = _smr_deleted_thread_time_max; + if (new_value <= cur_value) { + // No need to update max value so we're done. + break; + } + if (Atomic::cmpxchg(new_value, &_smr_deleted_thread_time_max, cur_value) == cur_value) { + // Updated max value so we're done. Otherwise try it all again. + break; + } + } + } + + inline void Threads::add_smr_deleted_thread_times(jint add_value) { + Atomic::add(add_value, &_smr_deleted_thread_times); + } + + inline void Threads::inc_smr_tlh_cnt() { + Atomic::inc(&_smr_tlh_cnt); + } + + inline void Threads::update_smr_tlh_time_max(jint new_value) { + while (true) { + jint cur_value = _smr_tlh_time_max; + if (new_value <= cur_value) { + // No need to update max value so we're done. + break; + } + if (Atomic::cmpxchg(new_value, &_smr_tlh_time_max, cur_value) == cur_value) { + // Updated max value so we're done. Otherwise try it all again. + break; + } + } + } + + inline void Threads::add_smr_tlh_times(jint add_value) { + Atomic::add(add_value, &_smr_tlh_times); + } + #endif // SHARE_VM_RUNTIME_THREAD_INLINE_HPP
< prev index next >