producer-consumer 相关问题

生产者 - 消费者问题(也称为有界缓冲问题)是多进程同步问题的经典示例。该问题描述了两个进程,生产者和使用者,他们共享一个用作队列的通用固定大小缓冲区。

在Producer范例中读取文本文件

[一个任务是在生产者范例中读取文本文件。生产者接口定义如下:公共接口Producer {/ ** *产生下一项。 * ...

回答 1 投票 0

读取生产者范例中的文本文件

[一个任务是在生产者范例中读取文本文件。生产者接口定义如下:公共接口Producer {/ ** *产生下一项。 * ...

回答 1 投票 0

kafka如何使用Scala将参数传递给消费者

我需要将参数传递给我的使用者,如果我写1则我的组ID为true,但我不知道如何传递参数。我将Intelliji配置为接受参数,但是我不知道如何传递它...

回答 1 投票 1

生产者-消费者问题,不使用诸如AtomicInteger和SynchronizedList之类的线程安全类

我是编程新手,过去只做过Python。我正在处理一个大学作业,涉及使用多线程概念在Java中实现生产者-消费者问题。在此...

回答 2 投票 0

CDI @产生Javadoc要求说明

我想知道@Produces Javadoc中描述的这一要求:如果生产者方法有时返回空值,或者如果生产者字段在访问时有时包含空值,...

回答 1 投票 1

BlockingQueue-一个生产者多个消费者

我有三个线程。线程1(T1)是生产者,它生成数据。线程2和3(分别为T2,T3)分别等待T1的数据在单独的循环中进行处理。我正在考虑共享一个...

回答 1 投票 0

生产者-消费者问题-尝试保存到csv文件中

所以这个看似简单的问题正在引起我的注意。我有一个数据集(数据),并且对其进行了一些处理(这不是问题,尽管由于数据集的大小,这需要时间)。 。

回答 1 投票 -1

生产者-消费者同步问题

我正在尝试编写一个简单的生产者-消费者应用程序,在该应用程序中,我需要从文件中读取大块数据(可能很大),并且(出于简单测试目的)只需通过另一个文件将其写入另一个文件...] >

回答 1 投票 2

c#生产者-消费者同步问题

我正在尝试编写一个简单的生产者-消费者应用程序,在该应用程序中,我需要从文件中读取大块数据(可能很大),并且(出于简单测试目的)只需通过另一个文件将其写入另一个文件...] >

回答 1 投票 2

任务并行库中的优先队列

是否有任何先后的工作以不同的优先级向TPL运行时添加任务?如果没有,一般而言,我将如何实施?理想情况下,我计划使用生产者-消费者模式来......>

回答 3 投票 4

如何理解您的应用程序是否已在Java的多线程消费者生产者方案中完成计算

我正在尝试Java中的多线程,这是我以前从未做过的事情。我目前正在尝试设计的宠物应用程序有一个阻塞队列和几个工作程序。应用程序...

回答 1 投票 0

连续将Runnable任务提交给ExecutorService,直到工作完成,并获取java.util.concurrent.RejectedExecutionException

我的多线程类应该对ClassA类的许多对象执行三种操作-operation1,operation2和operation3,其中每种类型的操作都取决于...

回答 1 投票 1

使用信号量在生产者和消费者之间实现同步的问题

像所有人一样,我试图更好地了解linux操作系统。我正在使用信号量实现生产者消费者同步问题。 i)将有m个生产者过程和n个消费者...

回答 2 投票 0

生产者/消费者问题-更改信号量顺序

假设我有一个多生产者和一个消费者场景。生产者的伪代码为:product = Produce()wait(空)wait(互斥量)array [in] = product in =(in + 1)%n signal(...

回答 1 投票 -1

Kafka经纪人可能不可用,例外

我与我的卡夫卡制片人面对一个奇怪的问题。我使用kafka-0.11服务器/客户端版本。我有一个Zookeper和一个kafka经纪人节点。另外,我创建了具有3个分区的“事件”主题:Topic:events ...

回答 1 投票 2

我如何使其运行更快?

我可以执行线程而不是任务来加快运行速度吗?我正在尝试将114000个产品添加到数据库中。由于我的代码是正确的,所以我每分钟将大约100种产品输入数据库。我的任务(...

回答 2 投票 0

将信任库证书添加到Apache Kafka而不反弹Kafka集群

我们正在使用Apache kafka_2.11-1.1.0。每当我们要添加新的Kafka生产者或使用者时,我们都会在truststore中更新新证书。添加证书后,我们必须重新启动kafka ...

回答 1 投票 0

Java生产者/消费者并发问题-尝试读取对象时出现NoSuchElementFound异常

我们有生产者消费者的这种实现方式。有时我们在readRecord()方法中得到NoSuchElementException。理想情况下,不应使用if语句,并且方法为...

回答 2 投票 0

问题调试生产者消费者问题

我试图了解生产者消费者问题。为了复制该问题,我编写了以下代码包com.company;。导入java.util.ArrayDeque;导入java.util.Queue;公共类...

回答 1 投票 0

生产者使用者使用Java中的等待和通知功能

我已经使用Java中的等待和通知机制准备了生产者使用者。下面是代码:类Producer实现Runnable {private int i = 0;私有ArrayList ... ...>

回答 2 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.