多线程:生产者-消费者问题中的忙碌等待

文章/答案/技术大牛

发布

2回答

.NET如何执行“顺序”线程利用

.net、multithreading

我使用的是一个多线程的生产者/消费者队列，它只有一个(非常快的)生产者和许多慢得多的消费者。每个消费者都可以独占访问一块物理硬件，例如电话线。生产者在主线程上运行，每个使用者在自己的线程上运行。我尝试做的是总是使用第一个消费者，如果它是可用的，如果它是繁忙的，那么使用第二个消费者。如

浏览 1提问于2010-07-05得票数 1

回答已采纳

1回答

c、multithreading、mutex、producer-consumer、busy-waiting

pthread_cond_destroy(&has_data); } 这段代码通过参数产生给定数字范围内的一个数字但是生产者产生一个超出范围的数字，如果它符合条件，就不会加入。消费者也是。例如，当我给出0~39(total_item = 500)，buff大小30(max_buf_size)，num_workers 5，num_master 3这样的数字范围时，它不会产生和消耗数字，只有它产

浏览 23提问于2020-11-29得票数 0

1回答

线程同步- CPU使用量超过200 -c程序

performance、c、multithreading、pthreads

我有一个工作程序，它读取用户输入键并使用生产者/使用者范例将它们回显到屏幕(该项目要求您使用线程)。虽然这个程序确实有效，但不幸的是它效率很低。当我运行“top”命令时，CPU使用率超过200。有任何修改代码的建议吗?这样它就不会消耗掉CPU的很大一部分？这是我第一个使用线程的程序，所以我不确定我是否做错了什么，如果这是正常的哈哈。提前谢谢。

浏览 0提问于2020-10-29得票数 4

1回答

生产者-消费者:我应该同步读访问吗

scala、synchronization

考虑生产者-消费者问题，有一个生产者和几个消费者。消费者等待，直到他们被告知已经产生了价值。生产者写入一个值并通知所有消费者，然后消费者读取该值。最后:使用屏障同步消费者和生产者的终止。问:我是否应该为消费者提供读取值的独占访问权限(例如，同步)(或者为生产者提供写操作？)我知道最明显的答案是

浏览 2提问于2013-04-20得票数 0

2回答

具有多个显示器的BlockingQueue设计

java、synchronization、blocking、monitor、java.util.concurrent

我正在编写一个BlockingQueue，我想知道其他实现如何解决这个问题：BlockingQu

浏览 2提问于2011-10-29得票数 2

回答已采纳

1回答

阻止生产者直到消费者完成(反向BlockingCollection)

c#、asp.net、.net、producer-consumer、blockingcollection

我想要一个多生产者-单一消费者模式，生产者等待直到消费者完成。因为这是一个多线程环境，我需要使用者一个一个地处理项目。我希望避免手动放置锁(因为可能存在缺陷)，并使用类似奇妙的.Take()方法来阻止消费者，直到产生更多的项目为止，但我也需要相反的方法： 消费者应该等待产品，生产者应该等待

浏览 0提问于2018-06-06得票数 1

1回答

JMS中的多线程

java、multithreading、asynchronous、jms、synchronous

我需要编写一个多线程JMS生产者和一个多线程JMS消费者；我对使用JMS比较陌生，以前从未使用过多线程。我在API中看到，您可以使用生产者的完成侦听器和消费者的消息侦听器异步发送和接收消息。这是否意味着使用完成侦听器和消息侦听器会导致程序多线程？如果没有，那么如何编写多线程生产者和多线程消费者呢？

浏览 1提问于2015-06-08得票数 1

1回答

卡夫卡镜片制造者:消费者对消费者的线号和生产者号

apache-kafka、kafka-consumer-api、kafka-producer-api、apache-kafka-connect

我想要明确指出卡夫卡平行模式的镜子制造者。我的疑问是:我们是单线程还是多线程的消费者？消费者群体指的是一组消费者还是一个多线程

浏览 4提问于2016-11-04得票数 1

回答已采纳

3回答

很难理解消费者生产者问题中的一个问题

c、operating-system、semaphore

我真的很难理解消费者生产者问题中的一个问题，例如在下面的图片中，关于消费者的简单结构：我的大问题是，在等待(互斥)和信号(互斥)中，参数互斥是相同的，因此，如果信号(互斥)被阻塞，信号(互斥)唤醒等待(互斥)过程是有意义的，但在等待(完全)和信号(空)中它们传递不同的参数，这样信号(空)如何才能唤醒等待(满)？(值得注意的</

浏览 6提问于2013-10-20得票数 0

回答已采纳

2回答

如何在ActiveMQ中获取所有入队的消息？

java、activemq

我想构建一个简单的消费者程序(用java编写)，以便将所有消息存储在一个ActiveMQ主题中。我有一个生产者，它发送队列中的TextMessage。但我不知道如何开始编写我的消费者检索旧消息，并等待新的消息。这是我的制片人：当我在消费者之前运行我的生产者，然后运行消费者<

浏览 0提问于2012-05-29得票数 5

回答已采纳

2回答

在监视器上等待的线程

java、multithreading

关于我在公司工作的一个应用程序的性能改进，人们一直在谈论。这个应用程序包含的预定任务在某个小时做了大量的xml parsing.At，当许多这样的任务被触发时，应用程序变得很慢。我一直在查看在这样一个高峰时间收集的线程转储，看看problem..But是什么新的这种练习，我不能理解it.Below的大部分是线程转储的摘录。:747) Loc

浏览 2提问于2011-12-01得票数 1

1回答

使用Posix信号量检测请求

c、request、posix、semaphore

您知道我们可以将消息队列与函数mq_receive()一起使用；使用信号量实现该功能(您知道，等待共享数据被更改)的好方法是什么？

浏览 0提问于2010-04-03得票数 0

回答已采纳

1回答

用于多线程的Scala迭代器

multithreading、scala、iterator、thread-safety、synchronized

我使用scala Iterator在synchronized块中进行等待循环： if (Try(anObject.foo()).isFailureTry(anObject.foo()) }} 在并发和多线程中使用Iterator是可以接受的吗？并且有多个生产者和消费者排队。因此，上面的代码块是这样的</

浏览 0提问于2020-05-15得票数 1

1回答

b/w生产者/使用者的本质区别是什么&写/读多线程建模？

c++、multithreading

在访问多线程建模问题时，有两个模型经常被问到：我的问题是，我无法理解这两种模式之间的本质区别。我对这两种模型的理解如下:对于生产者/消费者模型，生产者直到某些终止标准，在此条件下，生产者向消费者发出信号，等待另一个条件变量，而消费者则等到产品生产完毕，然后继续“消费”，通知

浏览 1提问于2017-05-22得票数 0

1回答

Pthread Mutex: pthread_mutex_unlock()耗费大量时间

multithreading、pthreads、mutex、intel-vtune

我用pthread编写了一个多线程程序，使用生产者-消费者模型。当我使用英特尔VTune profiler分析我的程序时，我发现生产者和消费者在pthread_mutex_unlock上花费了大量时间。我不明白为什么会发生这种事。我认为线程可能会等待很长时间才能获得互斥锁，但释放互斥锁应该很快，对吧？下面的快照来自英特尔VTune。它显示了消费者尝试从缓冲区获取项目的代码，以及每个代码行所消耗的时间。我的问题是，为

浏览 4提问于2013-06-03得票数 15

回答已采纳

2回答

在C#中使用第三方逻辑的生产者-消费者模式中的异常处理

c#、multithreading

我正在使用第三方公共许可证支持在C#中实现多线程生产者-消费者模式。有了方便的BlockingCollection和Task类，这项工作就变得很简单，除非我需要处理异常。众所周知，当BlockingCollection中没有可供消费的项目时，使用者Tasks对象将被阻塞，为了防止这些任务无限等待，调用BlockingCollection.CompleteAdding()显式地告诉每个人没有项目添加到BlockingCollection并唤醒任何正在等待的</em

浏览 3提问于2010-09-21得票数 1

回答已采纳

2回答

传递pthread_mutex_t到函数

c、multithreading、ipc

我之所以要求这样做，是因为我有很多线程，比如10，充当使用者，和2个生产者，每个使用者线程都有自己的链接列表(缓冲器)，生产者会根据特定的规则将数据发送到这些线程中的一个，所以有时候生产者1发送给消费者1，然后再发送给消费者2，然后返回到消费者1等等。所以我在想这个， 生产者1调用函数链接-列表来共享数据(IPC)并将lock5传

浏览 1提问于2012-12-25得票数 0

1回答

使用TCP客户端/服务器的生产者/消费者

c、tcp、pthreads

服务器旨在成为一个多线程服务器，它通过TCP在生产者或消费者连接时产生新的线程。我的问题是，一旦生产者客户端填满了队列，我就会陷入等待状态。这段代码显示了服务器对生产者连接的处理。生产者发送的请求格式为PUT (item) if ( strncmp(reqline[0], "PUT\

浏览 0提问于2012-03-07得票数 0

回答已采纳

1回答

Java中通知和等待的排序

java、multithreading、concurrency

我正在尝试写一个生产者消费者代码。下面是我编写的原始代码。consumerThread9.start(); consumerThread10.start(); 这段代码总是过时的。尽管应用程序没有终止，但它停止打印任何意味着没有线程进入同步块的任何内容。根据建议，我尝试更改代码，以便有两个独立的对象供生产者和使用者锁定

浏览 1提问于2018-12-21得票数 0

1回答

使用Spring Boot的多线程事务性Kafka生产者和消费者

multithreading、spring-boot、apache-kafka、spring-kafka、spring-transactions

我想在项目中使用Kafka的消费者和生产者的事务功能。我需要尽可能高效地在Kafka中产生大量的消息。所以我需要一个多线程的消费和生产来满足这个需求。如何使用Spring boot开发多线程消费者和生产者？

浏览 81提问于2020-10-14得票数 0

回答已采纳

点击加载更多

.NET如何执行“顺序”线程利用