producer-consumer

2热度

2回答

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

1热度

1回答

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

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

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

1热度

2回答

AWS设备农场“运行Calabash测试后没有发现要执行的套件”

我试过用几种不同的方式提交测试，但不断收到此错误。有人有主意吗？下面是我在提交我的测试格式。 mytests.zip -features - step_definitions - steps.rb - moresteps.rb - support - app_installation_hooks.rb - app_lif

2热度

4回答

如何避免dcast（）输出中的NA列？

如何避免NA列dcast()从reshape2封装输出？在该虚设示例的dcast()输出将包括NA柱： require(reshape2) data(iris) iris[ , "Species2"] <- iris[ , "Species"] iris[ 2:7, "Species2"] <- NA (x <- dcast(iris, Species ~ Species2, value

0热度

1回答

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

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

0热度

3回答

URL重定向issue.in asp.net mvc

当我创建一个新的记录时，我试图用这个重定向到编辑页面。 return RedirectToAction("Edit", "Organization", new { OrgId = organization.OrgId }); 但是，结果是这样的。 http://localhost:1626/Organization/Edit?OrgId=5 当它应该是 http://localhost:1

2热度

1回答

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

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

0热度

1回答

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

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

0热度

1回答

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

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