并发 - 实现信号量的监视器答案

【问题标题】：Concurrency - A monitor that implements semaphores并发 - 实现信号量的监视器
【发布时间】：2011-04-05 21:43:59
【问题描述】：

我需要帮助构建一个实现信号量的监视器，简单的 C 示例就可以了。

这是为了证明可以在任何可以使用信号量的地方使用监视器。

【问题讨论】：

使用条件变量可以吗？
Wikipedia page on Monitors 包含这样一个例子。

【解决方案1】：

如果你说 mutex/condvars 是允许的，那么检查一下：

#include <pthread.h>

typedef struct
{
  unsigned int count;
  pthread_mutex_t lock;
  pthread_cond_t cond;
} semaph_t;

int
semaph_init (semaph_t *s, unsigned int n)
{
  s->count = n;
  pthread_mutex_init (&s->lock, 0);
  pthread_cond_init (&s->cond, 0);
  return 0;
}

int
semaph_post (semaph_t *s)
{
  pthread_mutex_lock (&s->lock); // enter monitor
  if (s->count == 0)
    pthread_cond_signal (&s->cond); // signal condition
  ++s->count;
  pthread_mutex_unlock (&s->lock); // exit monitor
  return 0;
}

int
semaph_wait (semaph_t *s)
{
  pthread_mutex_lock (&s->lock); // enter monitor
  while (s->count == 0)
    pthread_cond_wait (&s->cond, &s->lock); // wait for condition
  --s->count;
  pthread_mutex_unlock (&s->lock); // exit monitor
  return 0;
}

【讨论】：

【解决方案2】：

这是Wikipedia article regarding monitors的主要答案。

monitor class Semaphore
{
  private int s := 0
  invariant s >= 0
  private Condition sIsPositive /* associated with s > 0 */

  public method P()
  {
    if s = 0 then wait sIsPositive
    assert s > 0
    s := s - 1
  }

  public method V()
  {
    s := s + 1
    assert s > 0
    signal sIsPositive
  }
}

【讨论】：