代码之家 › 专栏 › 技术社区 › jagamot

多线程应用程序-一些伪代码的帮助!

concurrency multithreading java

jagamot · 技术社区 · 16 年前

我正在开发一个多线程应用程序,需要一些伪代码的帮助。为了简化实现,我将尝试用简单的术语/测试用例来解释这一点。

下面是一个场景-

我有一个字符串数组列表(比如100个字符串)

我有一个Reader类,它读取字符串并将其传递给Writer类,Writer类将字符串打印到控制台。现在,它在单线程模型中运行。

我想让这个多线程,但有以下特点-

设置最大读卡器的能力

能够设置MAX_WRITERS

能够设置批量大小

因此,基本上,代码应该实例化这些读者和作者,并并行地完成工作。

任何伪代码都会让我继续前进!

2 回复 | 直到 16 年前

ilikeorangutans 16 年前

这听起来像是典型的消费者-生产者问题。看看 Wikipedia's article 关于它。那里有大量的伪代码。

Community Mohan Dere 9 年前

除了使用 producer-consumer pattern 有人建议,我建议你使用 CopyOnWriteArrayList 因此,您可以对列表进行无锁读/写/迭代。因为您只处理几百个字符串,所以可能不会有任何性能问题 CopyOnWriteArrayList .

如果你关心性能,那么我实际上认为如果你使用 BlockingQueue 或者 ConcurrentHashMap 。它们将使多线程应用程序的吞吐量最大化。

建议的选项是:
A. BlockingQueue 可以很好地与多个生产者和消费者合作,但这当然意味着数据处理顺序(FIFO)。如果你同意FIFO排序,那么你可能会发现 封锁队列 是一种更快、更稳健的选择。

我认为维基百科的文章有足够的伪代码供您使用,但您也可以查看以下一些问题:
https://stackoverflow.com/search?q=java+producer+consumer

推荐文章

ron burgundy · 获取-释放语义是否跨线程传递?[副本]

1 年前

H3007 · 并发运行python子进程似乎不是并发的

2 年前

The Oddler · TVar会阻止读取直到更改吗?

2 年前

Wang Tuma · 使用信号量的c++并发问题:按顺序打印

2 年前

Ahmed Bilal · Java CopyOnWriteArrayList添加元素(如果不存在)

2 年前

Saurabh Goyal · 为什么Tokio单线程风格不提供任何并发性?

2 年前

KundaliniSin · 异步函数的隐式Promise没有像我预期的那样解析

2 年前

Theodor Zoulias · 列出<T>。AddRange在将ConcurrentDictionary作为参数传递时引发ArgumentException

2 年前

Marcel Batista · 在不同线程中更新密钥时的字典线程安全

2 年前

rico · 当volatile关键字真的是必要的?

2 年前