在gstreamer中做线程同步，这里分别用到了C++ condition_variable和glib的GCond和GMutex做线程同步，C++代码用在外部代码，glib的用法用在pipeline的代码中。

C++ condition_variable的背景知识

使用条件变量condition_variable做线程同步，可用于阻止一个线程或同时阻止多个线程，直到另一个线程修改共享变量（condition），并通知condition_variable，才会继续执行。

当调用它的wait函数时，它使用一个mutex来锁定线程。使得该线程保持阻塞状态，直到被另一个线程调用同一个condition_variable对象上的notify函数才被唤醒。

condition_variable类型的对象必须使用unique_lock等待。

• wait 阻塞当前线程，直到notify_all()或notify_one()被执行。
• wait_for 阻塞当前线程，直到条件变量被唤醒或在指定的超时持续时间之后。
• wait_until 阻塞当前线程，直到唤醒条件变量或到达指定的时间点。

condition_variable的代码实例

本例中，ctrl+c的时候退出程序，所以下面signal_andler回调时，执行notify_all()：

注册signal_andler：

static std::mutex srv_mtx;
static std::condition_variable srv_cv;struct sigaction sa;
memset(&sa, 0, sizeof(sa));
sa.sa_handler = signal_andler;
sigfillset(&sa.sa_mask);
sigaction(SIGINT, &sa, NULL);

notify_all：

void signal_andler(int sig) {std::unique_lock lock(srv_mtx);server_exit = 1;srv_cv.notify_all();
}

wait的代码：

  std::unique_lock lock(srv_mtx);while (!server_exit) {printf("waiting ...\n");srv_cv.wait(lock);printf("done.\n");}

gstreamer mainloop的同步

在gstreamer pipeline中，mainloop在执行了g_main_loop_quit()之后，mainloop就会退出，所以需要对mainloop线程进行同步，释放thread资源。

定义GCond和GMutex：

  GCond main_loop_cond;GMutex main_loop_mutex;g_mutex_init(&main_loop_mutex);g_cond_init(&main_loop_cond);

如下，在g_main_loop_run()之后，lock之后修改main_loop_，broadcast之后然后释放锁：

  g_main_loop_run(player->main_loop_);g_mutex_lock(&player->main_loop_mutex);g_main_context_unref(player->context_);g_main_loop_unref(player->main_loop_);player->context_ = nullptr;player->main_loop_ = nullptr;g_cond_broadcast(&player->main_loop_cond);g_mutex_unlock(&player->main_loop_mutex);

在主线程，等待main_loop_的状态变化：

  gint64 end_time = g_get_monotonic_time () + 10 * G_TIME_SPAN_MILLISECOND;g_mutex_lock(&main_loop_mutex);while (main_loop_) {g_cond_wait_until(&main_loop_cond, &main_loop_mutex, end_time);}g_mutex_unlock(&main_loop_mutex);g_thread_unref(thread_);thread_ = nullptr;

或者是g_cond_wait，不带超时：

  g_mutex_lock(&main_loop_mutex);while (main_loop_) {g_cond_wait(&main_loop_cond, &main_loop_mutex);}g_mutex_unlock(&main_loop_mutex);g_thread_unref(thread_);thread_ = nullptr;

参考

std::condition_variable::wait