diff options
author | Nobuyoshi Nakada <nobu@ruby-lang.org> | 2021-06-15 15:55:52 +0900 |
---|---|---|
committer | Nobuyoshi Nakada <nobu@ruby-lang.org> | 2021-06-15 15:55:52 +0900 |
commit | b32e6c168a3463c1eda7a94f7716adbd3d607a38 (patch) | |
tree | b9496444080ca415cb0c8c1b5f864c2679f600e1 /thread_sync.c | |
parent | f0818982e947dc52d9ad57ccd02fe034b84ab374 (diff) |
Convert initial contents before allocating queue buffer
Diffstat (limited to 'thread_sync.c')
-rw-r--r-- | thread_sync.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/thread_sync.c b/thread_sync.c index e9eabb45ca..76bf57e4dd 100644 --- a/thread_sync.c +++ b/thread_sync.c @@ -859,11 +859,13 @@ rb_queue_initialize(int argc, VALUE *argv, VALUE self) { VALUE initial; struct rb_queue *q = queue_ptr(self); + if ((argc = rb_scan_args(argc, argv, "01", &initial)) == 1) { + initial = rb_to_array(initial); + } RB_OBJ_WRITE(self, &q->que, ary_buf_new()); list_head_init(queue_waitq(q)); - rb_scan_args(argc, argv, "01", &initial); if (argc == 1) { - rb_ary_concat(q->que, rb_to_array(initial)); + rb_ary_concat(q->que, initial); } return self; } |