producer-consumer

0热度

1回答

如何纠正循环阵列插入索引

我正在尝试在动态循环数组中找到插入前端的公式。我遇到的一个问题是当尝试运行显示时，在这种情况下，前两次插入后的inx将因为没有被占用的索引而关闭。这是假设我正在按照正确的方式选择开始索引。 void insertCDAfront(CDA *items,void *val){//insert in the slot prior t assert(items->array!=0);

c producer-consumer 2017-09-14

---

2热度

1回答

TCP套接字服务器的CPU时间超过限制'

这个问题提出了运行使用生产者/消费者设计创建了一个socket服务器的同时，程序日志，错误cpu time limit exceeded坠毁。我还发现，cpu使用率超过90%的时间。这里是服务器的代码，它可能会出错，我该如何优化？ 我用这个方法queue以避免为每个请求的那么多的threads创建。 在主方法（主线程） //holds socket instances ConcurrentLin

java multithreading sockets concurrency producer-consumer 2017-11-11

---

0热度

1回答

工人阻止消费 - RabbitMQ - Node.js

我在Node.js中遇到了RabbitMQ问题。 我试图实现一个Pub/Sub连接器，其中每个用户都有自己的队列轮询以获取消息。 当我通过Postma发布邮件并且用户使用邮件时，我没有任何问题（我正确地获取邮件），而如果用户试图使用队列中的邮件（但不存在邮件），它会一直卡住，直到发布了新的发布，但我无法获得该消息。 我想要做的是放弃消耗，然后重试。 你能帮我解决吗？ get_queue工作正常，并

node.js rabbitmq publish-subscribe producer-consumer 2017-09-24

---

0热度

1回答

One Producer十个消费者文件处理与Executors.newSingleThreadExecutor（）

我有一个LinkedBlockingQueue任意挑选的容量为10，并有1000行输入文件。据我所知，我在服务类的main方法中有一个ExecutorService类型变量，它使用Executors.newSingleThreadExecutor() - 一个单独的线程调用buffer.readline（），直到文件line == null，然后处理 - 在循环使用Executors.newSin

java multithreading batch-processing executorservice producer-consumer 2017-09-26

---

2热度

2回答

在同一个互斥量上使用两个std :: unique_lock会导致死锁？

我发现这个code在代码审查堆栈交换，它实现了生产者 - 消费者问题。我在这里发布一段代码。 在给定的代码，让我们考虑一个场景时，制片人致电void add(int num)产生价值，它获取的是互斥锁mu和buffer.size()==size_这使得在等待队列中的生产者进入，由于条件变量cond。 同时发生上下文切换并且消费者调用函数int remove()消耗值，它尝试获取互斥锁mu上的锁，但

c++ mutex deadlock producer-consumer unique-lock 2017-10-06

---

1热度

1回答

C管道：错误的文件描述符

我有简单的生产者消费者程序在C尝试用fork解决它 生产者试图在管道上写入时我得到错误： 我已经写了另一个程序具有相同的逻辑，但这一个不知道为什么？ 生产者未能写管道项目：为什么我得到这个错误，错误的文件描述符 任何人有想法？ 由于 #define READ 0 #define WRITE 1 int mutex = 1, full = 0, empty = BUFFER_SIZE, x =

c fork producer-consumer 2017-11-25

---

0热度

1回答

如何使用kafka-avro-console-producer？

如果我使用'kafka-console-producer' - 它会自动拾取JASS文件并正常运行（可以产生远程主题）。 如果我使用“卡夫卡的Avro控制台生产者”与完全相同的配置但增加了架构属性 - 它抱怨JASS配置： 'Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.s

properties apache-kafka producer-consumer producer 2017-10-12

---

5热度

1回答

如何从任何两个BlockingCollections中获取优先于第一个集合的项目？

我有两个BlockingCollection<T>对象，collection1和collection2。我想要消耗这些集合中的物品，并优先处理collection1中的物品。也就是说，如果两个藏品都有物品，我想首先从collection1获取物品。如果他们都没有物品，我想等待物品可用。 我有以下代码： public static T Take<T>( BlockingCollection<

c# producer-consumer 2017-08-29

---

0热度

1回答

如何使用OpenMP在C++中实现监视器？

我正在使用C++编写Producer-consumer problem以及在使用OpenMP时如何实现显示器？ 我无法找到像OpenMP中conditional_variable任何东西，我不能执行等待/通知上像维基百科例如某些条件。

c++ multithreading openmp producer-consumer 2017-10-20

---

0热度

1回答

如何维护消费者线程的执行顺序

我正在为一个生产者和多个消费者运行代码。我想优先执行消费者线程。即如果我有consThread1，consThread2，consThread3。我的问题是如何限制consThread3 consThread1和consThread2 Producer.java import java.util.concurrent.BlockingQueue; import org.json.simple.J

java multithreading producer-consumer 2017-09-03

---