1
Fork 0
mirror of https://github.com/RGBCube/serenity synced 2025-07-25 15:57:45 +00:00

LibJS: Make WeakContainer pruning do less work

Instead of iterating *all* swept cells when pruning weak containers,
only iterate the cells actually *in* the container.

Also, instead of compiling a list of all swept cells, we can simply
check the Cell::state() flag to know if something should be pruned.
This commit is contained in:
Andreas Kling 2021-10-05 18:44:31 +02:00
parent 19fc225b45
commit 83bd675477
10 changed files with 39 additions and 35 deletions

View file

@ -216,22 +216,18 @@ void Heap::sweep_dead_cells(bool print_report, const Core::ElapsedTimer& measure
dbgln_if(HEAP_DEBUG, "sweep_dead_cells:"); dbgln_if(HEAP_DEBUG, "sweep_dead_cells:");
Vector<HeapBlock*, 32> empty_blocks; Vector<HeapBlock*, 32> empty_blocks;
Vector<HeapBlock*, 32> full_blocks_that_became_usable; Vector<HeapBlock*, 32> full_blocks_that_became_usable;
Vector<Cell*> swept_cells;
size_t collected_cells = 0; size_t collected_cells = 0;
size_t live_cells = 0; size_t live_cells = 0;
size_t collected_cell_bytes = 0; size_t collected_cell_bytes = 0;
size_t live_cell_bytes = 0; size_t live_cell_bytes = 0;
auto should_store_swept_cells = !m_weak_containers.is_empty();
for_each_block([&](auto& block) { for_each_block([&](auto& block) {
bool block_has_live_cells = false; bool block_has_live_cells = false;
bool block_was_full = block.is_full(); bool block_was_full = block.is_full();
block.template for_each_cell_in_state<Cell::State::Live>([&](Cell* cell) { block.template for_each_cell_in_state<Cell::State::Live>([&](Cell* cell) {
if (!cell->is_marked()) { if (!cell->is_marked()) {
dbgln_if(HEAP_DEBUG, " ~ {}", cell); dbgln_if(HEAP_DEBUG, " ~ {}", cell);
if (should_store_swept_cells)
swept_cells.append(cell);
#ifdef JS_TRACK_ZOMBIE_CELLS #ifdef JS_TRACK_ZOMBIE_CELLS
if (m_zombify_dead_cells) { if (m_zombify_dead_cells) {
cell->set_state(Cell::State::Zombie); cell->set_state(Cell::State::Zombie);
@ -269,7 +265,7 @@ void Heap::sweep_dead_cells(bool print_report, const Core::ElapsedTimer& measure
} }
for (auto& weak_container : m_weak_containers) for (auto& weak_container : m_weak_containers)
weak_container.remove_swept_cells({}, swept_cells.span()); weak_container.remove_dead_cells({});
if constexpr (HEAP_DEBUG) { if constexpr (HEAP_DEBUG) {
for_each_block([&](auto& block) { for_each_block([&](auto& block) {

View file

@ -42,19 +42,17 @@ bool FinalizationRegistry::remove_by_token(Object& unregister_token)
return removed; return removed;
} }
void FinalizationRegistry::remove_swept_cells(Badge<Heap>, Span<Cell*> cells) void FinalizationRegistry::remove_dead_cells(Badge<Heap>)
{ {
auto any_cells_were_swept = false; auto any_cells_were_removed = false;
for (auto* cell : cells) { for (auto& record : m_records) {
for (auto& record : m_records) { if (!record.target || record.target->state() == Cell::State::Live)
if (record.target != cell) continue;
continue; record.target = nullptr;
record.target = nullptr; any_cells_were_removed = true;
any_cells_were_swept = true; break;
break;
}
} }
if (any_cells_were_swept) if (any_cells_were_removed)
vm().enqueue_finalization_registry_cleanup_job(*this); vm().enqueue_finalization_registry_cleanup_job(*this);
} }

View file

@ -30,7 +30,7 @@ public:
bool remove_by_token(Object& unregister_token); bool remove_by_token(Object& unregister_token);
void cleanup(FunctionObject* callback = nullptr); void cleanup(FunctionObject* callback = nullptr);
virtual void remove_swept_cells(Badge<Heap>, Span<Cell*>) override; virtual void remove_dead_cells(Badge<Heap>) override;
private: private:
virtual void visit_edges(Visitor& visitor) override; virtual void visit_edges(Visitor& visitor) override;

View file

@ -15,7 +15,7 @@ public:
explicit WeakContainer(Heap&); explicit WeakContainer(Heap&);
virtual ~WeakContainer(); virtual ~WeakContainer();
virtual void remove_swept_cells(Badge<Heap>, Span<Cell*>) = 0; virtual void remove_dead_cells(Badge<Heap>) = 0;
protected: protected:
void deregister(); void deregister();

View file

@ -23,9 +23,15 @@ WeakMap::~WeakMap()
{ {
} }
void WeakMap::remove_swept_cells(Badge<Heap>, Span<Cell*> cells) void WeakMap::remove_dead_cells(Badge<Heap>)
{ {
for (auto* cell : cells) // FIXME: Do this in a single pass.
Vector<Cell*> to_remove;
for (auto& it : m_values) {
if (it.key->state() != Cell::State::Live)
to_remove.append(it.key);
}
for (auto* cell : to_remove)
m_values.remove(cell); m_values.remove(cell);
} }

View file

@ -27,7 +27,7 @@ public:
HashMap<Cell*, Value> const& values() const { return m_values; }; HashMap<Cell*, Value> const& values() const { return m_values; };
HashMap<Cell*, Value>& values() { return m_values; }; HashMap<Cell*, Value>& values() { return m_values; };
virtual void remove_swept_cells(Badge<Heap>, Span<Cell*>) override; virtual void remove_dead_cells(Badge<Heap>) override;
private: private:
#ifdef JS_TRACK_ZOMBIE_CELLS #ifdef JS_TRACK_ZOMBIE_CELLS

View file

@ -25,18 +25,16 @@ WeakRef::~WeakRef()
{ {
} }
void WeakRef::remove_swept_cells(Badge<Heap>, Span<Cell*> cells) void WeakRef::remove_dead_cells(Badge<Heap>)
{ {
VERIFY(m_value); VERIFY(m_value);
for (auto* cell : cells) { if (m_value->state() == Cell::State::Live)
if (m_value != cell) return;
continue;
m_value = nullptr; m_value = nullptr;
// This is an optimization, we deregister from the garbage collector early (even if we were not garbage collected ourself yet) // This is an optimization, we deregister from the garbage collector early (even if we were not garbage collected ourself yet)
// to reduce the garbage collection overhead, which we can do because a cleared weak ref cannot be reused. // to reduce the garbage collection overhead, which we can do because a cleared weak ref cannot be reused.
WeakContainer::deregister(); WeakContainer::deregister();
break;
}
} }
void WeakRef::visit_edges(Visitor& visitor) void WeakRef::visit_edges(Visitor& visitor)

View file

@ -27,7 +27,7 @@ public:
void update_execution_generation() { m_last_execution_generation = vm().execution_generation(); }; void update_execution_generation() { m_last_execution_generation = vm().execution_generation(); };
virtual void remove_swept_cells(Badge<Heap>, Span<Cell*>) override; virtual void remove_dead_cells(Badge<Heap>) override;
private: private:
virtual void visit_edges(Visitor&) override; virtual void visit_edges(Visitor&) override;

View file

@ -23,9 +23,15 @@ WeakSet::~WeakSet()
{ {
} }
void WeakSet::remove_swept_cells(Badge<Heap>, Span<Cell*> cells) void WeakSet::remove_dead_cells(Badge<Heap>)
{ {
for (auto* cell : cells) // FIXME: Do this in a single pass.
Vector<Cell*> to_remove;
for (auto* cell : m_values) {
if (cell->state() != Cell::State::Live)
to_remove.append(cell);
}
for (auto* cell : to_remove)
m_values.remove(cell); m_values.remove(cell);
} }

View file

@ -27,7 +27,7 @@ public:
HashTable<Cell*> const& values() const { return m_values; }; HashTable<Cell*> const& values() const { return m_values; };
HashTable<Cell*>& values() { return m_values; }; HashTable<Cell*>& values() { return m_values; };
virtual void remove_swept_cells(Badge<Heap>, Span<Cell*>) override; virtual void remove_dead_cells(Badge<Heap>) override;
private: private:
#ifdef JS_TRACK_ZOMBIE_CELLS #ifdef JS_TRACK_ZOMBIE_CELLS