// Copyright (c) 2014 Baidu.com, Inc. All Rights Reserved // Author: Ge,Jun (gejun@baidu.com) // Date: Tue Sep 30 16:52:32 CST 2014 #include <gtest/gtest.h> #include "base/time.h" #include "base/macros.h" #include "base/logging.h" #include "bthread/task_group.h" #include "bthread/bthread.h" namespace { void* sleeper(void* arg) { bthread_usleep((long)arg); return NULL; } TEST(ListTest, join_thread_by_list) { bthread_list_t list; ASSERT_EQ(0, bthread_list_init(&list, 0, 0)); std::vector<bthread_t> tids; for (size_t i = 0; i < 10; ++i) { bthread_t th; ASSERT_EQ(0, bthread_start_urgent( &th, NULL, sleeper, (void*)10000/*10ms*/)); ASSERT_EQ(0, bthread_list_add(&list, th)); tids.push_back(th); } ASSERT_EQ(0, bthread_list_join(&list)); for (size_t i = 0; i < tids.size(); ++i) { ASSERT_FALSE(bthread::TaskGroup::exists(tids[i])); } bthread_list_destroy(&list); } TEST(ListTest, join_a_destroyed_list) { bthread_list_t list; ASSERT_EQ(0, bthread_list_init(&list, 0, 0)); bthread_t th; ASSERT_EQ(0, bthread_start_urgent( &th, NULL, sleeper, (void*)10000/*10ms*/)); ASSERT_EQ(0, bthread_list_add(&list, th)); ASSERT_EQ(0, bthread_list_join(&list)); bthread_list_destroy(&list); ASSERT_EQ(EINVAL, bthread_list_join(&list)); } } // namespace