我正在编写一个多线程应用程序,其中有 n 个生产者尝试将元素添加到共享资源。我想维护生产者在共享资源中生成元素的顺序。
例如,我的共享资源是 SynchronizedQueue,P1、P2、P3、P4 将按照 p1、p2、p3、p4 的顺序生成新元素,在此期间 P5 生产者将其元素添加到队列中,因此 P1, P2、P3、P4将等待锁定。一旦 P5 释放锁,P1-4 中的任何一个都将获取锁,因此我们失去了元素的顺序。
有没有办法维持等待锁的元素的顺序?根据我的理解,这是不可能的,但我想检查是否可以通过编程来实现。
我能想到的一种方法是创建一个包装类,PriorityP
其中有字段int priority
and P value
.
然后为每个线程分配一个优先级(int
)并且线程给出结果 aPriorityP
具有适当的优先级和值。
现在,您可以使用PriorityBlockingQueue而不是你的SynchronizedQueue
,并实施Comparator界面中的PriorityP
class.
当您这样做时,每当线程将其值输入队列时,它就会自动放入正确的位置。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)