8374690: ZGC: Convert zRelocate to use Atomic<T>

Reviewed-by: stefank, tschatzl
This commit is contained in:
Axel Boldt-Christmas 2026-01-27 08:42:44 +00:00
parent bd92c68ef0
commit 6fda44172e
2 changed files with 17 additions and 16 deletions

View File

@ -1,5 +1,5 @@
/* /*
* Copyright (c) 2015, 2025, Oracle and/or its affiliates. All rights reserved. * Copyright (c) 2015, 2026, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
* *
* This code is free software; you can redistribute it and/or modify it * This code is free software; you can redistribute it and/or modify it
@ -64,31 +64,31 @@ ZRelocateQueue::ZRelocateQueue()
_needs_attention(0) {} _needs_attention(0) {}
bool ZRelocateQueue::needs_attention() const { bool ZRelocateQueue::needs_attention() const {
return AtomicAccess::load(&_needs_attention) != 0; return _needs_attention.load_relaxed() != 0;
} }
void ZRelocateQueue::inc_needs_attention() { void ZRelocateQueue::inc_needs_attention() {
const int needs_attention = AtomicAccess::add(&_needs_attention, 1); const int needs_attention = _needs_attention.add_then_fetch(1);
assert(needs_attention == 1 || needs_attention == 2, "Invalid state"); assert(needs_attention == 1 || needs_attention == 2, "Invalid state");
} }
void ZRelocateQueue::dec_needs_attention() { void ZRelocateQueue::dec_needs_attention() {
const int needs_attention = AtomicAccess::sub(&_needs_attention, 1); const int needs_attention = _needs_attention.sub_then_fetch(1);
assert(needs_attention == 0 || needs_attention == 1, "Invalid state"); assert(needs_attention == 0 || needs_attention == 1, "Invalid state");
} }
void ZRelocateQueue::activate(uint nworkers) { void ZRelocateQueue::activate(uint nworkers) {
_is_active = true; _is_active.store_relaxed(true);
join(nworkers); join(nworkers);
} }
void ZRelocateQueue::deactivate() { void ZRelocateQueue::deactivate() {
AtomicAccess::store(&_is_active, false); _is_active.store_relaxed(false);
clear(); clear();
} }
bool ZRelocateQueue::is_active() const { bool ZRelocateQueue::is_active() const {
return AtomicAccess::load(&_is_active); return _is_active.load_relaxed();
} }
void ZRelocateQueue::join(uint nworkers) { void ZRelocateQueue::join(uint nworkers) {
@ -453,7 +453,7 @@ static void retire_target_page(ZGeneration* generation, ZPage* page) {
class ZRelocateSmallAllocator { class ZRelocateSmallAllocator {
private: private:
ZGeneration* const _generation; ZGeneration* const _generation;
volatile size_t _in_place_count; Atomic<size_t> _in_place_count;
public: public:
ZRelocateSmallAllocator(ZGeneration* generation) ZRelocateSmallAllocator(ZGeneration* generation)
@ -463,7 +463,7 @@ public:
ZPage* alloc_and_retire_target_page(ZForwarding* forwarding, ZPage* target) { ZPage* alloc_and_retire_target_page(ZForwarding* forwarding, ZPage* target) {
ZPage* const page = alloc_page(forwarding); ZPage* const page = alloc_page(forwarding);
if (page == nullptr) { if (page == nullptr) {
AtomicAccess::inc(&_in_place_count); _in_place_count.add_then_fetch(1u);
} }
if (target != nullptr) { if (target != nullptr) {
@ -493,7 +493,7 @@ public:
} }
size_t in_place_count() const { size_t in_place_count() const {
return _in_place_count; return _in_place_count.load_relaxed();
} }
}; };
@ -503,7 +503,7 @@ private:
ZConditionLock _lock; ZConditionLock _lock;
ZRelocationTargets* _shared_targets; ZRelocationTargets* _shared_targets;
bool _in_place; bool _in_place;
volatile size_t _in_place_count; Atomic<size_t> _in_place_count;
public: public:
ZRelocateMediumAllocator(ZGeneration* generation, ZRelocationTargets* shared_targets) ZRelocateMediumAllocator(ZGeneration* generation, ZRelocationTargets* shared_targets)
@ -539,7 +539,7 @@ public:
ZPage* const to_page = alloc_page(forwarding); ZPage* const to_page = alloc_page(forwarding);
_shared_targets->set(partition_id, to_age, to_page); _shared_targets->set(partition_id, to_age, to_page);
if (to_page == nullptr) { if (to_page == nullptr) {
AtomicAccess::inc(&_in_place_count); _in_place_count.add_then_fetch(1u);
_in_place = true; _in_place = true;
} }
@ -579,7 +579,7 @@ public:
} }
size_t in_place_count() const { size_t in_place_count() const {
return _in_place_count; return _in_place_count.load_relaxed();
} }
}; };

View File

@ -1,5 +1,5 @@
/* /*
* Copyright (c) 2015, 2025, Oracle and/or its affiliates. All rights reserved. * Copyright (c) 2015, 2026, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
* *
* This code is free software; you can redistribute it and/or modify it * This code is free software; you can redistribute it and/or modify it
@ -28,6 +28,7 @@
#include "gc/z/zPageAge.hpp" #include "gc/z/zPageAge.hpp"
#include "gc/z/zRelocationSet.hpp" #include "gc/z/zRelocationSet.hpp"
#include "gc/z/zValue.hpp" #include "gc/z/zValue.hpp"
#include "runtime/atomic.hpp"
class ZForwarding; class ZForwarding;
class ZGeneration; class ZGeneration;
@ -42,8 +43,8 @@ private:
uint _nworkers; uint _nworkers;
uint _nsynchronized; uint _nsynchronized;
bool _synchronize; bool _synchronize;
volatile bool _is_active; Atomic<bool> _is_active;
volatile int _needs_attention; Atomic<int> _needs_attention;
bool needs_attention() const; bool needs_attention() const;
void inc_needs_attention(); void inc_needs_attention();