实现信号量

Question

似乎glib提供了互斥体和条件作为线程同步原语，但通用semaphores（从它支持原始P和V操作的意义上说）我正确理解GCond等同于二进制信号量，其中g_cond_signal相当于P，而g_cond_wait相当于V？但是，信号量不限于最大值1？

我认为是这样的：

struct semaphore { 
    int n; 
    GMutex sem_lock; 
    GCond sem_cond; 
} 

凡P操作现在看起来是这样的：

void semaphore_P (struct semaphore *sem) 
{ 
    g_mutex_lock(sem->sem_lock); 
    while (sem->n == 0) 
    g_cond_wait(sem->sem_cond, sem->sem_lock); 
    --sem->n; 
    g_mutex_unlock(sem->sem_lock); 
} 

有没有一种简单的方法来获得其中的并行线程sem_wait功能和sem_post从glib内？

Answer 1

asynchronous queue一个可以用作信号量：

• 初始化：GAsyncQueue *队列= g_async_queue_new（）; g_async_queue_push（queue，GINT_TO_POINTER（1））; g_async_queue_push（队列，GINT_TO_POINTER（1））; g_async_queue_push（队列，GINT_TO_POINTER（1））; g_async_queue_push

• P操作：g_async_queue_pop（queue）;

的队列的大小作为信号量的计数器。 g_async_queue_push的第二个参数可以是除NULL以外的任何指针。 但是，如果您想为一些消费者/生产者任务使用信号量，那么发送指向某些数据的指针将会很有用。

在某些情况下，a thread pool可能更适合。