问题标签 [producer]

所以我正在查看我的下一个学校作业，我很困惑。我想我会向专家寻求一些指导。我严重缺乏同步方面的知识，而且我对它所指的“mcopyfile”任务也没有那么热情。可怕的可能是一个好词。如果我能就如何解决这个问题获得一些指导，将不胜感激。不是找人来做我的任务，只需要有人给我指出正确的方向。婴儿步骤。

基于您在 Lab 2 中创建的多线程文件复制工具（mcopyfile），现在请使用工作池（Producer-Consumer 模型）实现，该实现使用固定数量的线程来处理负载（无论在要复制的目录）。您的程序应创建 1 个文件复制生产者线程和多个文件复制消费者线程（此数字取自命令行参数）。文件复制生产者线程将在有界大小的缓冲区结构中生成（源和目标）文件描述符列表。每次生产者访问缓冲区时，它将写入一个（源，目标）文件条目（每次访问）。并且所有的文件复制消费者线程都会从这个缓冲区中读取，执行实际的文件复制任务，并删除相应的文件条目（每个消费者每次都会消费一个条目）。生产者和消费者线程都会向标准输出写入一条消息，给出文件名和完成状态（例如，对于生产者：“正在完成将文件 1 放入缓冲区”，对于消费者：“正在完成将文件 1 复制到……”）。

我正在尝试让 perl 生产者与 ActiveMq 交谈。请找到我尝试过的代码。它给了我一个错误 “* Net::STOMP::Client::IO::receive_data(): cannot sysread(): EOF”**

调试错误后，$stomp->connect(); 请让我知道为什么此时出现此错误...我无法在线找到有关此问题的太多帮助..

提前致谢

我试图远程登录到我试图连接的 url。首先它正在连接，最后它是一些错误消息，如下所示：

这意味着连接正在关闭。

这些是我怀疑有错误的代理日志：

代码：

我的要求是维护一个固定大小的缓存，它为基于 Java 的 Web 应用程序中的多个消费者和单个生产者提供支持。我的数据是这样的：

键 1，键 2，值

123，ABC，列表1

123，定义，列表2

234，xyz，列表3

客户端或消费者将根据 key1 和 key2 查询此缓存。因此，如果多个消费者尝试同时访问相同 key1 和 2 的缓存，他们都应该从缓存中获取相同的数据作为响应。

我正在寻找可能使用的最佳数据结构。另请注意，缓存大小是固定的，因此如果生产者在尝试插入记录之前应该删除第一个元素（如果缓存已满）。

我目前在地图中使用地图。即键 1 用于外部映射，键 2 用于内部映射。但是，我需要查看它以获取我认为效率低下的信息。

有什么建议吗？

我发现在 Kafka 0.72 中，我们可以指定 zk.connect 或 broker.list。但是在 Kafka 0.8 中，我们只能指定 broker.list ，不能指定 zk.connect 而不指定 broker.list。我认为，在这种情况下，我们无法通过 zookeeper 来平衡生产者。如果有人使用Kafka 0.8，或者对此有所了解？非常感谢！

生产者方法对于以编程方式创建实例并在上下文中发布它们非常有用。new问题是由生产者方法创建和返回的实例的所有属性都不是由 CDI 注入的。在 Weld 文档中，我读到这是一种有意的行为，但在许多情况下，注入这些 bean 会非常有用。

是否有解决方法可以注入此类 bean？

akka doc (http://doc.akka.io/docs/akka/2.1.0/scala/camel.html) shows that camel procedure is an actor:

what are the differences between a camel producer and a regular actor, for example, does producer has mailbox and dispatcher, which i can set in my code?

我有一个很容易并行化的简单任务。基本上，相同的操作必须在一个（大的，几个 Gb）输入文件的每一行上重复执行。虽然我已经制作了一个多线程版本，但我注意到我的 I/O 是瓶颈。我决定构建一个实用程序类，其中包含一个“文件读取器”线程，该线程简单地直接向前读取并尽可能快地读取到循环缓冲区中。然后，多个消费者可以调用这个类并获得他们的“下一行”。给定 n 个线程，每个线程 i 的起始行是文件中的第 i 行，并且通过添加 n 找到该线程的每个后续行。事实证明，这不需要锁，几个关键的原子操作足以保留不变量。

我已经测试了代码，它似乎更快，但再想一想，我不知道为什么。将大文件分成 n 个输入文件不是一样快吗（您可以提前“搜索”到同一个文件中以实现相同的目的，最少的预处理），然后让每个进程简单地调用 iostream::readLine on它自己的块？（因为 iostream 也会读入它自己的缓冲区）。在多个线程之间共享单个缓冲区似乎没有任何固有的优势，因为工作人员实际上并不是在同一行数据上操作。另外，我认为没有什么好的方法可以并行化，这样它们就可以在同一条线上工作。我只想了解我所看到的性能提升，并知道它是“flukey”还是跨平台可扩展/可重现......

根据 JConsole 堆栈跟踪，我有一组生产者-消费者线程，但生产者卡在了一行不是..put()

根据堆栈跟踪，它只是停留while(true)在行上，没有通过循环前进，即使它应该。

第 25 行是该while(true) {行。

我正在使用 Camel 的 POJO 生产，例如

{

}

使用方法 sayHello 的接口与在骆驼中用作主体的字符串对象。但是，如果我在这里尝试使用任何其他对象，我会从骆驼那里得到异常，说没有找到用于转换 java.io.InputStream 的 BeanInvocation 的 TypeConvertor。

我知道该对象是被允许的，它会在某处被提及。但我想解释为什么它会这样做，以及是否有办法解决这个问题。

I am trying to understand producer consumer problem via above code .When i execute the above code i am getting

Program gets stuck here only (do not gets terminate).

Someone Please explain what wrong i am doing here?