使用 Posix 信号量检测请求

发布于 2024-08-28 05:51:25 字数 71 浏览 9 评论 0原文

您知道我们可以通过函数 mq_receive() 使用消息队列;使用信号量实现该功能(您知道,等待共享数据更改)的好方法是什么?

You know we can use message queues with the function mq_receive(); what is a good way to implement that functionality (you know, waiting until the shared data is changed) with semaphores?

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

玉环 2024-09-04 05:51:25

标准方式:

  • 消费者等待生产者信号量表明有东西可供消费者消费。
  • 当有东西可供消费者消费时,产品就会向信号量发出信号。

如果您有多个消费者和多个生产者,您可以确保信号量有足够的范围以允许生产者对多个请求进行排队,并且确保消费者知道如何处理其中可能有多个同时处于活动状态的请求。不过,所有这些都是标准的多处理(多线程)理论。

如果您需要所需操作的概要,那么您需要查看 POSIX 手册页:

System V IPC

  • semctl()
  • semget()
  • semop()

POSIX IPC

  • sem_close()
  • sem_destroy()
  • sem_getvalue()
  • sem_init()
  • sem_open()
  • sem_post()
  • sem_timedwait()
  • sem_trywait()
  • sem_unlink()
  • sem_wait ()

The standard way:

  • The consumer waits on the semaphore for the producer to indicate that there is something ready for the consumer to consume.
  • The produce signals the semaphore when there is something ready for the consumer to consume.

If you have multiple consumers and multiple producers, you ensure that the semaphore has enough range to allow for multiple requests to be queued by the producers and you ensure that the consumers know how to handle perhaps several of them being active at once. All of this is standard multi-processing (multi-threading) theory, though.

If you need a run-down on the operations required, then you need to look at the POSIX manual pages for:

System V IPC

  • semctl()
  • semget()
  • semop()

POSIX IPC

  • sem_close()
  • sem_destroy()
  • sem_getvalue()
  • sem_init()
  • sem_open()
  • sem_post()
  • sem_timedwait()
  • sem_trywait()
  • sem_unlink()
  • sem_wait()
~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文