我正在开发一个使用Java开发的基于多线程的Web应用程序。
我在该应用程序中有两个线程，类似于生产者和消费者，其中一个线程不断地从第三方API (套接字连接)读取数据，并将其更新到缓存中。另一个线程(使用者)不断尝试从缓存中读取数据。
我的问题是，当数据发生变化时，是否有任何方法可以提高使用者线程的性能(我的意思是它只从缓存中读取数据)。
浏览 2提问于2012-09-17得票数 0
回答已采纳
我编写了一个代码，用于查看Java中的生产者-消费者关系，如下所示。虽然程序运行良好，但我看到输出中有不一致之处。有谁能说明以下不一致的原因吗？
class ProdCons2
{
public static void main (String [] args)
{
Shared s = new Shared ();
new Producer (s).start ();
new Consumer (s).start ();
}
}
class Shared
{
private char c = '\u0000';
浏览 0提问于2013-11-11得票数 1
回答已采纳
2回答
我正在从事一个使用PubSub( GCP )的项目，我的问题并不是针对GCP的，而是更多地涉及到体系结构模式(我习惯于静态类型化语言，我很难找到如何以正确的方式做到这一点)。
我正在处理的服务是用go编写的，我想要的(至少对我来说，这似乎是正确的方法)是强制使用者和生产者使用相同的消息格式(在编译时商定模式)。现在，这两个部分是完全独立的，所以我们在两个地方指定了消息格式(这确实让我感到烦恼)。
一开始，我认为消费者应该拥有信息格式(不要认为我是这种架构的新手)，和同事讨论了一下，然后做了一些阅读，我同意这会打破模式，因为生产者会了解消费者，当你有多个消费者时，也会出现一个问题。
我的下一个想
浏览 0提问于2020-05-06得票数 1
回答已采纳
1回答
我正在尝试了解Rest代理解决方案是否可以在我的解决方案中帮助我。我评论说： 我正在尝试从我的前端(react)发送一个图像，以响应由我的应用程序的客户端生成的事件。该图像被发送给制作人卡夫卡，卡夫卡将派他的消费者在几种机器学习模型中处理它，并将响应返回给该制作人。 流程： 前端(img) -> ApiRest (Spring Boot) ->生产者->消费者(Python) ->向客户端返回响应。 我知道我需要Kafka作为一个请求-响应，将响应返回给发出事件的客户端。 我找对地方了吗？ 另一方面，我想知道在同一主题中使用不同语言(Java和Python)的几个使用
浏览 26提问于2019-04-08得票数 0
我有一个下面的python代码，它在python - python PUB/SUB ZeroMQ ( pyzmq )场景中成功工作。
我可以通过c++订阅这个python服务器吗？
我还添加了一个c++客户端代码，但它不起作用。
Python：
def send_array_and_str(socket, img, string, flags=0):
global count
print(count , " sended")
## numpy array gönderirken shape bilgilerini de msg olarak eklem
浏览 6提问于2020-04-17得票数 1
1回答
带有条件变量的Java互斥关联
、、、、
Java中的每个条件变量(wait()、notify())都与单个互斥(同步)相关联。
我曾说过(在Java中)，每个互斥对象也与一个条件变量相关联，这是一个比p线程的cond变量和互斥变量更低效率的实现。然而，我无法理解这一条。那是什么意思？Java与C/C++线程在这个问题上有什么不同？
浏览 3提问于2016-01-31得票数 2
回答已采纳
1回答
我只想检查一下我认为正确的答案。
Process producer {
while(1) {
// produce c
lock(empty);
lock(mutex);
data = c;
unlock(mutex);
unlock(full);
}
}
Process consumer {
while(1) {
lock(full);
lock(mutex);
c = data;
unlock(mutex);
unlock(empty);
// consume c
}
}
有多少互斥锁在使用中？
浏览 0提问于2016-04-05得票数 0
我对卡夫卡很陌生。我有以下架构：
1) 2 servers runing application logics and database, can I write kafka producer on these servers wrapped with docker container ?
2) 1 server reserved for kafka broker and zookeeper
3) 1 sever reserved for kafka comsumer
我很困惑
1) whether I can run kafka producer, broker and consumer
浏览 6提问于2015-11-02得票数 0
回答已采纳
1回答
我正在尝试更好地理解c编程中的fork()和并发性。我是一个新手，我在理解逻辑上有困难。我尝试使用fork()创建一个简单的生产者-消费者程序。基本上，producer()函数应该从stdin中获取一个字符，并将其写入一个文件。同时，第二个进程运行consumer代码，该代码将读取文件中的最后一个字符并将其回显到屏幕上。producer()和consumer()函数本身工作得很好，即它们都在做各自应该做的事情，但问题出在并发性上。下面是我的代码：
#include<stdio.h>
#include <stdlib.h>
#include <unistd.h>
浏览 0提问于2019-04-30得票数 0
1回答
重入锁和同步的实现是如何不同的？
、、、、
根据java源代码
ReentrantLock的锁(不公平)如下。
public boolean lock(){
int c=getState();
if(c==0){
compareAndSetState(0,1);
}
}
//getState method
public int getState(){
return state;
}
public boolean compareAndSetState(int expected,int update){
unsafe.compareAndSwapInt(this, sta
浏览 3提问于2017-03-26得票数 0
回答已采纳
1回答
我的两根线，生产和消费，不工作很好。当我运行这段代码时，控制台一个一个地打印“产生”和“消费”。然后，它停止了，程序仍然是running>。
class BufferMutex {
private char [] buffer;
private int count = 0, in = 0, out = 0;
private ReentrantLock mutex = new ReentrantLock();
private Condition okProduce = mutex.newCondition();
private Condition
浏览 3提问于2022-05-18得票数 0
回答已采纳
1回答
在观察者模式中，主体和观察者之间通常存在一对多的关系(有一个主体和多个观察者)。
但我有一个问题，在我的实现中，有许多主题(例如: A、B、C)返回对象，但是只有一个观察者(例如: O)将这些主题的输出放入队列中，然后一个接一个地处理它们。
我可以使用什么样的设计模式/范例呢？
浏览 4提问于2016-04-12得票数 0
回答已采纳
3回答
我想创建一个线程，它在队列为空时将值放入队列，并在队列不为空时等待该条件。下面是我尝试使用的代码，但它打印出来
Adding new
Taking Value 1
Taking Value 2
Taking Value 3
Taking Value 4
所以它只工作一次。有什么问题吗？
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
public class SO {
public String test;
public String[]
浏览 1提问于2010-02-28得票数 1
回答已采纳
我有一个关于2个代理的3个分区的主题。(Kafka版本: 0.8.1)
使用不同的用户guid (例如: FC42B34DD7658503E040970A2C437358)作为分区键批量添加消息。(约10k条消息)
加载消息时，我有一个正在运行的使用者(consumer1)，它开始很好地处理消息。
然后，我使用相同的消费者组id启动了另一个消费者(consumer2)。
我注意到的是，consumer1停止处理消息，而consumer2开始处理所有消息。
当我停止consumer2时，consumer1接管并恢复消息处理。
我希望两个消费者都能分担负载。
有什么线索可能是问题所在吗？谢谢。
浏览 0提问于2015-03-28得票数 1
我在练习这个著名的应用程序，我有一个问题。我发现在这个网站上有4000多个关于这个话题的问题，但是没有一个是与这一点有关的，所以我问这个问题。
以下是简单的代码-
class Resource {
int contents;
boolean available = false;
}
class Producer implements Runnable {
Thread t;
private Resource resource;
public Producer(Resource c) {
resource = c;
t=
浏览 4提问于2014-07-12得票数 0
回答已采纳
我有以下实体:生产者，消费者。
A Producer produces Food for the Consumer.
A Consumer consumes Food produced by the Producer.
现在，我的任务是设计一个模式，该模式映射消费者可以食用每个生产者生产的食物。
举个例子，我有生产者p1，p2，p3和消费者c1，c2，c3。
c1 c2 c3
p1 N Y N
p2 Y N N
p3 N N Y
where N = No and Y = Yes
记住
消费者和生产者的数量将继续增长。
消费者是否可以从新生产
浏览 0提问于2018-02-09得票数 0
1回答
我有以下实体:生产者，消费者。
A Producer produces Food for the Consumer.
A Consumer consumes Food produced by the Producer.
现在，我的任务是设计一个模式，该模式映射消费者可以食用每个生产者生产的食物。
举个例子，我有生产者p1，p2，p3和消费者c1，c2，c3。
c1 c2 c3
p1 N Y N
p2 Y N N
p3 N N Y
where N = No and Y = Yes
记住
消费者和生产者的数量将继续增长。
消费者是否可以从新生产者那里食
浏览 0提问于2018-02-08得票数 1
我的问题与之前提出的有关。在我使用队列在生产者线程和消费者线程之间进行通信的情况下，人们通常会推荐使用LinkedBlockingQueue或ConcurrentLinkedQueue
使用一种比另一种有什么优点/缺点？
从API的角度来看，我能看到的主要区别是，LinkedBlockingQueue可以是可选的绑定。
浏览 2提问于2009-09-15得票数 120
回答已采纳
1回答
我的场景：
我有一个制片人和一个消费者。两者都是大猩猩，它们通过一个渠道进行交流。
生产者能够(理论上)在任何时候产生一条消息。
生成消息需要一些计算。
这条信息有点时间敏感性(也就是说，它越老，它的相关性就越小)。
消费者偶尔从频道上阅读。为了这个例子，假设使用者每隔几秒钟使用一个time.Ticker来读取一条消息。
消费者更喜欢“新鲜”消息(即最近生成的消息)。
因此，问题是：，生产者如何能够尽可能晚地生成消息？
显示一般思想的示例代码：
func producer() {
for {
select {
...
浏览 0提问于2019-06-12得票数 0
2回答
我面临着并行化一个简单的轮询过程循环，这个循环如下所示：
while(!done)
buffer = poll(...)
foreach(item i in buffer)
process(i)
该问题遵循单个生产者/多个消费者模式，除非所产生的产品必须由所有的使用者消费。
考虑到实现必须是多线程C++代码，我应该使用什么样的数据结构？
谢谢你的建议！
浏览 2提问于2015-01-20得票数 1
1回答
在C# .NET 4.0中，有一个取自
示例BC_AddTakeCompleteAdding
我的问题是.NET中的SQLCommand.ExecuteNonQuery返回了错误的行数。
更新是在主键上进行的，所以应该只有一行。
有时会得到正确的数字。
通常在.NET中得到大于1 (100-10000)的数字。
即使在对相同的PK运行完全相同的TSQL时，它也不总是相同的错误数字。
可以将TSQL复制粘贴到SSMS中，每次都能得到正确答案(1)。
update [docSVsys] set [FTSstatus] = '1', [FTSdate] = '10/23/
浏览 2提问于2012-10-23得票数 0
回答已采纳
6回答
我正在看一个关于Java多线程的视频教程。介绍了用Java实现著名的“生产者-消费者”问题。
它使用wait()和notifyAll()来确保生产者线程和消费者线程之间的正确通信。
这位导师故意创建了几个生产者线程，而只有一个消费者线程，但他留下了一个未回答的问题：“最好是生产者线程和消费者线程的数量相等，如果生产者线程比消费者线程多，就会有问题”。
然而，他没有具体说明问题是什么。我个人认为这只是一种篮子满了的情况。专家们能在这方面提供帮助吗？谢谢。
浏览 2提问于2013-04-05得票数 5
回答已采纳
我已经在本地机器上设置了apache kafka，并且工作正常，当我将一条消息发布到生产者中时，它立即在消费者提示中流动。
可以从我的本地文件夹配置连续文件流吗？我该怎么做呢？
我可以编写一个java应用程序来配置我的生产者吗？
浏览 0提问于2016-07-28得票数 0
1回答
背景
下面的代码片段摘自的题为VisualC# 2005:如何编程(第735页)。代码片段或多或少是一个通过缓冲区(称为shared)使用2个线程访问数据的应用程序。只需跳过代码片段，然后查看下面的内容，如果您想要简短地描述正在发生的事情(在阅读我的问题之前)。
// Fig. 15.8: UnsynchronizedBufferTest.cs
// Showing multiple threads modifying a shared object without
// synchronization.
using System;
using System.Threading;
class
浏览 0提问于2016-05-23得票数 4
回答已采纳
2回答
我的任务是使用线程和信号量来解决生产者和消费者的问题。任务是允许用户定义生产者#、消费者#和缓冲区大小。如果producer达到缓冲区大小，程序将始终锁定。但是要求指出，如果生产者达到buffersiz，消费者线程应该启动并从buffer中获取内容。我不知道如何解决这个问题，我的老师拒绝帮助我。我完全是一个C语言的初学者，请给我一些建议。非常感谢
我的程序可以在Producer = Consumer或Producer < Consumer时运行，除了Producer >缓冲区大小，它似乎出现死锁，我想我理解其中的原因，但我不知道如何修复代码，让Consumer线程先运行，而不是返回
浏览 2提问于2012-03-27得票数 1
回答已采纳
我有一个SimpleProducerConsumer类，它说明了一个消费者/生产者问题(我不确定它是否正确)。
public class SimpleProducerConsumer {
private Stack<Object> stack = new Stack<Object>();
private static final int STACK_MAX_SIZE = 10;
public static void main(String[] args) {
SimpleProducerConsumer pc = new Sim
浏览 3提问于2012-03-28得票数 0
回答已采纳
1回答
我的服务器上运行了一个C++模拟。同时，还有基于C#的代码，主要用于统计数据收集。C#代码格式化并使用由C++代码生成的日志。这两个程序在同一台机器上运行。我将模拟生成日志的过程称为“生产者”，将另一个将日志格式化为“消费者”的过程称为“消费者”。
在系统中运行的生产者有多个副本。事实上，系统中最多可以同时运行20个生产者。只有一份消费者的副本。生产者日志具有唯一的is，用于标识日志来自哪个模拟。
假设我有大量可用内存，那么生产者和消费者沟通的最佳方法是什么？
此时，每个生产者可以生成高达100 logs的日志。因此，将生成的最大日志量将为2 2GBps。我怀疑消费者可能无法吸收那么多的吞吐量
浏览 1提问于2018-06-30得票数 0
2回答
我刚刚阅读了有关基于合同的测试以验证微服务之间的合同的文章：
微服务体系结构中的测试策略
消费者驱动契约:一种服务演化模式
在我的公司，我们的团队已经建立了一个其他应用程序(B，C，D，.)使用的REST服务(A)。其他球队的。我想知道我们应该如何落实这一想法。我设想这个过程是这样的：
我们为其他团队提供访问测试存储库的权限。
其他团队，比如说B组，提供拉请求测试，测试它们的应用程序B对我们的合同A的行为。
我们接受他们的请求
作为构建的一部分，我们从其他使用者(其应用程序使用我们的服务的团队)运行测试。
我的问题：
这是否正确的理解？我有遗漏什么吗？
消费者测试应该是什么样的呢？应该是一个真
浏览 0提问于2017-04-16得票数 1
5回答
我目前正在尝试将CCR理解为一个异步编程模型。在过去，我使用了标准的begin/end方法。我主要是用VB.net开发的，并且一直在渴望地看着输出/枚举器的技巧。
你最喜欢的异步模式是什么？
浏览 0提问于2009-01-31得票数 3
1回答
多线程批处理队列
、、、、
我目前正在编写一个TCP侦听器，它有许多客户端应用程序向发送短消息。我拥有的TCP listener是一个C# winform，我需要做的是批量处理这些日志，以避免在队列中收到的每条消息都命中数据库。目前，对于侦听器中收到的每条消息，我都会使用C# Queue类进行入队。
一个单独的线程将每5分钟执行一次，以检查该队列，如果有任何排队的项目，则开始处理该队列。这种设计似乎存在并发/争用条件问题，因为当5分钟线程启动时，正在接收的新消息不能再访问队列，因为我在DeQueue期间锁定了它。因此，这些新消息会丢失。似乎只有在有大量消息发送到TCP侦听器时才会发生这种情况。
有没有人认为这是我的一个有
浏览 1提问于2012-11-25得票数 3
我们是否可以在RabbitMQ中设计发布-订阅模式，其中消费者也可以充当生产者并将消息发送到消息代理？ pub-sub with the same service
浏览 47提问于2020-02-01得票数 0
回答已采纳
我正在开发的应用程序有一个问题。
我有两个线程，Prod和Cons，它们分别写入和读取共享的Queue。这里的一切都很标准。
这个应用程序的目标是让Prod读取一个文件并将每一行添加到Queue，而Cons则必须读取这些行并成对地“匹配”它们(遵循一些标准)。
问题是，为了让Cons完成它的一部分，它将不得不“处理”Queue中的几行，并且只删除构成一对的那些行。例如，如果下面是由Prod填充的Queue Q：
Q:
-
A1
A2
B1
C1
D1
C2
D2
B2
E1
E2
Cons应创建对(A1，A2)、(B1，B2)、(C1，C2)等...(该
浏览 0提问于2013-04-25得票数 2
回答已采纳
3回答
我试图解决这个问题，但它被证明是困难的。
我有两个线程，一个是生产者，另一个是消费者。都在不同的类中。这两个线程独立运行。生产者汇集了大约8-12个文件夹用于输入。然后，它会同时翻译所有文件，并将其放入名为“readyToLoad”的共享文件夹中。一旦生产者线程完成，消费者线程现在进入'readyToLoad‘文件夹，并开始处理翻译后的文档。
现在的问题是，当消费者正在处理翻译的文档时，它不允许生产者在'readyToLoad‘文件夹中放入更多的翻译文件。
我的问题是，我如何防止消费者锁定'readyToLoad‘文件夹？我该如何处理这种情况？
很抱歉我的文本很长，但我
浏览 0提问于2013-07-19得票数 1
我有两个通过DS (声明性服务)注册的EventHandlers。现在，有了另一个名为EventAdmin.sendEvent()的DS服务。当事件被触发时，只有一个EventHandlers接收事件，因为它们中的一个似乎没有准备好。因此，当第二个EventHandler可用时，就太晚了，因为该事件已经被消费了。两个EventHandlers都在@Component注释中设置了immediate=true。
有没有一种“优雅”的方法来解决这个问题？
浏览 8提问于2017-01-21得票数 0
回答已采纳
我想使用WPF DataTrigger来检查大于X的值。我知道这只有IValueConverter才有可能。我已经找到了很多这样的C#示例，但我需要在powershell中使用它。有人能帮我把这个翻译成powershell吗？
要转换的C#代码：
public class CutoffConverter : IValueConverter {
public object ConvertTo(object obj, Type type) {
return ((int)obj) > Cutoff;
}
public object ConvertFro
浏览 2提问于2013-01-11得票数 1
回答已采纳
3回答
有没有任何方法可以暂停或节流卡夫卡的生产者基于消费者滞后或其他消费问题？生产者是否需要确定自己是否存在消费滞后，然后进行节流？
浏览 0提问于2019-01-14得票数 5
回答已采纳
下面的代码片段在我的JUnit测试用例类中。我使用了三个线程来测试一个名为SharedResources的类；getGuy只是其中之一。我的问题是在启动线程后，只有第一个线程读取sharedResource，而且只有一次。
Thread getGuy = new Thread(new Runnable() {
public void run() {
for(int i=0; i < 5; i++) {
try {
Thread.sleep(500);
浏览 0提问于2011-08-17得票数 0
1回答
从下面的数据和代码中，我试图制作一个多点图，但问题是塑料生产中的塑料消费是重叠的，我希望两者相互聚集，而不是重叠。
structure(list(Country = c("China", "Indonesia", "Vietnam", "Thailand",
"Egypt", "India", "Turkey", "Brazil", "United States", "Russia"
),
Plastic.Consumption =
浏览 0提问于2020-12-10得票数 0
1回答
我刚刚开始为我们的微服务设置提供消费者驱动的合同，因为它们主要是Spring应用程序，所以自然的选择是Spring合同。但随之而来的是混乱。在docs中的所有示例中，合同都是在生产者端定义的，使用者从maven repo中检索它们。如果生产者定义了它们，它是如何由消费者驱动的？
我的理解是，在概念上，使用者将它们定义为它对它所使用的API的一部分的生产者的期望。除了前面的问题之外，Spring契约是否能够在使用者端定义合同并在生产者身上验证它呢？
浏览 0提问于2019-08-01得票数 7
回答已采纳
可以使用JMeter向Apache Kafka推送消息吗？
如何实现producer ( JAVA)向Kafka推送消息。
致敬，阿南德
浏览 6提问于2015-03-30得票数 1
我有一个线程流数据和第二个(线程池)处理数据。数据处理大约需要100ms，所以我使用第二个线程，这样就不会占用第一个线程。
当第二个线程处理数据时，第一个线程将数据添加到字典缓存，然后当第二个线程完成时，它处理缓存的值。
我的问题是，在C#中应该如何做生产者/consumer代码？
public delegate void OnValue(ulong value);
public class Runner
{
public event OnValue OnValueEvent;
private readonly IDictionary<string, ulong>
浏览 0提问于2010-09-03得票数 2
回答已采纳
我有一个C#服务器应用程序，它需要与另外3个客户端应用程序进行对话和控制:一个在C#中，一个在C++中，一个在VB.Net中。它们都是Windows窗体应用程序。它们基本上需要交换一些字符串和数字，而不是繁重的负载。在C#和这些不同的语言之间进行进程间通信的最佳方式是什么？请注意，客户端并不相互通信，它们只与服务器通信。
C#需要与C++对话，所以我猜WCF不是很好，因为WCF只能在两个.Net应用程序之间工作？
我可以在所有这些语言中方便地使用命名管道吗: C#、C++和VB.Net？
我还想知道，如果将来我必须添加VB6、VBScript和PowerShell脚本作为客户端，那么在所有这6
浏览 3提问于2011-05-13得票数 1
回答已采纳
我有两条骆驼路线的申请：
1号干线(消费者路线)
读取没有的文本文件。对于记录(分隔行)，根据每一行拆分它们，并将每个拆分记录发送到另一个队列(“中间”队列)。
2号干线(生产者路线)
从中间队列读取每个记录，转换它们并将它们发送到一个out队列。
我用的是ActiveMQ和骆驼JmsComponent (concurrentConsumers=7, maxConcurrentConsumers=10)。我猜骆驼在下面使用Spring从队列中读取。
Configurations
activemq.broker.uri = tcp://0.0.0.0:61616?jms.useA
浏览 1提问于2016-06-22得票数 3
我看过一些关于操作系统概念的书，提到了在同步并发访问共享资源的情况下生产者-消费者问题。所有这些似乎都在共享内存体系结构中。
生产者-消费者问题是否出现在分布式内存体系结构中进程之间的通信中？如果是，
生产者所产生的输出是否存储在与使用者共享的地方？
执行相同的同步方法(例如锁、信号量、监视器、.)应用于共享内存体系结构中的生产者-消费者问题在分布式内存体系结构中？
我看到“管道”和“流处理”这两个词很流行。它们是指生产者-消费者的问题/模式吗？它们是否需要与共享内存体系结构相同的同步方法？
谢谢。
浏览 0提问于2019-12-19得票数 1
2回答
我使用node-amqp。对于每个队列，都有一个发送者和一个消费者。在发送方，我需要维护一个活动消费者列表。问题是，当消费者计算机崩溃时，我如何收到通知并将其从发送者端的列表中删除？
浏览 0提问于2012-10-28得票数 3
1回答
我已经创建了一个FIFO，我可以用这种方式向其中进行非阻塞写入：
// others, searching for a non-blocking FIFO-writer may copy this ;-)
mkfifo("/tmp/myfifo", S_IRWXU);
int fifo_fd = open("/tmp/myfifo", O_RDWR);
fcntl(fifo_fd, F_SETFL, fcntl(fifo_fd, F_GETFL) | O_NONBLOCK);
// and then in a loop:
LOGI("Writing i
浏览 0提问于2013-01-28得票数 5
回答已采纳
2回答
我尝试了一个生产者/消费者
生产者
#pragma once
#ifndef PRODUCER_H
#define PRODUCER_H
#include <thread>
#include "Mailbox.h"
class Producer
{
private:
std::thread producer;
Mailbox& mailbox;
public:
Producer(Mailbox& newmailbox);
~Producer();
void start();
void run();
浏览 2提问于2017-10-13得票数 0
1回答
我遇到了生产者消费者的情况，其中我使用了arrayblockingqueue。如果消费者线程出现异常，如何停止生产者线程。我需要producer停止等待队列为空。我诱导了一个强制的运行时异常。但是程序不会退出。生产者一直在等待队列为空。有人能帮帮忙吗？ public class ServiceClass implements Runnable{
private final static BlockingQueue<Integer> processQueue = new ArrayBlockingQueue<>(10);
private static
浏览 15提问于2019-09-28得票数 1
回答已采纳
3回答
我正在使用boost库和C++。我想创建一个包含生产者、消费者和堆栈的多线程程序。procuder填充堆栈，消费者从堆栈中删除项(int)。一切都正常(弹出、推送、互斥)，但是当我在线程中调用弹出/推送时，我得不到任何效果
我写了这个简单的代码：
#include "stdafx.h"
#include <stack>
#include <iostream>
#include <algorithm>
#include <boost/shared_ptr.hpp>
#include <boost/thread.hpp>
浏览 4提问于2012-10-23得票数 0
回答已采纳
1回答
当生产者产生一条消息时，它必须被所有消费者消费，然后只有生产者才能产生第二条消息，而且所有消费者都必须消费它，依此类推。我试着写这段代码，但它不能按照requirement.can的要求工作，有人能帮帮忙吗？
package Demo3;
import java.util.concurrent.Semaphore;
public class ConsumerProducerMonitor {
// produces items
public synchronized void put(String item,int itemNo,Stri
浏览 3提问于2016-01-22得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
