Function TEST

test/bthread_cond_bug_unittest.cpp:123–141

}

TEST(BthreadCondBugTest, test_bug) {
    bthread_t tids[PRODUCER_NUM];
    for (int i = 0; i < PRODUCER_NUM; i++) {
        bthread_start_background(&tids[i], NULL, produce_func, (void*)(int64_t)i);
    }
    bthread_t tid;
    bthread_start_background(&tid, NULL, consume_func, NULL);

    int64_t ret = (int64_t)print_func(nullptr);

    bthread_stop(tid);
    bthread_join(tid, nullptr);
    for (int i = 0; i < PRODUCER_NUM; i++) {
        bthread_stop(tids[i]);
        bthread_join(tids[i], nullptr);
    }

    ASSERT_EQ(ret, 1);
}