Implementing multiple queue and single thread in Java

Question

Using Java I need to implement the following architecture: There are multiple queues with jobs continuously coming in the queues. There is a single thread picking up jobs from the queues following a scheduling algorithm. I should be able to write my own scheduling algorithm. Can you please tell me which Java API to use to implement this? I have used ThreadPoolExecutor, but with this I could implement a single job queue and a thread pool containing multiple threads. Thanks in advance!

Have you looked at all the implementations of the Queue interface in its javadoc? Pick your poison. — JB Nizet
– JB Nizet, Commented Jul 21, 2013 at 21:20
Actually I am able to implement queue. What I need is multiple queues and a single thread.. — kajarigd
– kajarigd, Commented Jul 21, 2013 at 21:27

Martin James · Accepted Answer · 2013-07-21 21:22:45Z

3

Use multiple concurrent queues and one semaphore. In the producers, push objects and signal the semaphore. In the one consumer, wait on the 'common' semaphore and then poll the queues according to your scheduling algorithm - one of them must have an object on it.

answered Jul 21, 2013 at 21:22

Martin James

25k4 gold badges39 silver badges60 bronze badges

Sign up to request clarification or add additional context in comments.

2 Comments

kajarigd Over a year ago

Thanks for your reply! Can you please tell me how to use multiple queues. I am not aware of any Java API, which will allow me to have multiple queues.

Stephen C Over a year ago

@user2110873 - there is no such API. You need to implement this yourself as described in this Answer.

Collectives™ on Stack Overflow

Implementing multiple queue and single thread in Java

1 Answer 1

2 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

2 Comments

Your Answer

Sign up or log in

Post as a guest

Related