mirror/ruby
1
0
Fork 0
mirror of https://github.com/ruby/ruby.git synced 2026-01-27 04:24:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make Thread::Queue and SizedQueue support compaction

Browse Source
This commit is contained in:
Peter Zhu 2025-08-27 09:54:40 -04:00
parent 6023195fbd
commit 2edfc51acf
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
thread_sync.c
View File

@ -694,12 +694,12 @@ struct rb_szqueue {
} RBIMPL_ATTR_PACKED_STRUCT_UNALIGNED_END();
static void
queue_mark(void *ptr)
queue_mark_and_move(void *ptr)
{
struct rb_queue *q = ptr;
/* no need to mark threads in waitq, they are on stack */
rb_gc_mark(q->que);
rb_gc_mark_and_move((VALUE *)UNALIGNED_MEMBER_PTR(q, que));
}
static size_t
@ -710,7 +710,7 @@ queue_memsize(const void *ptr)
static const rb_data_type_t queue_data_type = {
"queue",
{queue_mark, RUBY_TYPED_DEFAULT_FREE, queue_memsize,},
{queue_mark_and_move, RUBY_TYPED_DEFAULT_FREE, queue_memsize, queue_mark_and_move},
0, 0, RUBY_TYPED_FREE_IMMEDIATELY|RUBY_TYPED_WB_PROTECTED
};
@ -770,11 +770,11 @@ queue_timeout2hrtime(VALUE timeout)
}
static void
szqueue_mark(void *ptr)
szqueue_mark_and_move(void *ptr)
{
struct rb_szqueue *sq = ptr;
queue_mark(&sq->q);
queue_mark_and_move(&sq->q);
}
static size_t
@ -785,7 +785,7 @@ szqueue_memsize(const void *ptr)
static const rb_data_type_t szqueue_data_type = {
"sized_queue",
{szqueue_mark, RUBY_TYPED_DEFAULT_FREE, szqueue_memsize,},
{szqueue_mark_and_move, RUBY_TYPED_DEFAULT_FREE, szqueue_memsize, szqueue_mark_and_move},
0, 0, RUBY_TYPED_FREE_IMMEDIATELY|RUBY_TYPED_WB_PROTECTED
};