在gstreamer中做线程同步-创新互联

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

创新互联是专业的梁溪网站建设公司，梁溪接单;提供成都做网站、网站建设,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行梁溪网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!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_locklock(srv_mtx);
  server_exit = 1;
  srv_cv.notify_all();
}

wait的代码：

std::unique_locklock(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

你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧

名称栏目：在gstreamer中做线程同步-创新互联
标题路径：http://cxhlcq.com/article/hhpdi.html