How do I share single list between two infinite loop threads?

Question

I have data structure (i.e. queue, stack or list). There is infinite loop (in thread 1) that inserts objects into that data structure, and there is another infinite loop (in thread 2) that takes objects from that data structure and does some processing on it. I don't want the processing loop to block the insert loop.

How can I do this correctly in Java, to share a single data structure between two threads with synchronization and concurrent read/write from the two different threads? Is there any data structure in java concurrent API (java 7) that I can use? is there any recommendation to solve this issue?

have a look at java concurrency package https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/package-summary.html — Sleiman Jneidi, Nov 30 '15 at 12:09

score 5 · Accepted Answer · edited May 23 '17 at 12:07

5

What you are looking for is a non-blocking data structure, say ConcurrentLinkedQueue. It will accept entries to the queue and requests to it without blocking either, making it very simple to use without implementing anything fancy.

Further Reading (Into the theory behind non-blocking)

edited May 23 '17 at 12:07

Community

1
1

answered Nov 30 '15 at 12:08

Ross Drew

8,163
2
41
53

1

Thanks @Ross for sharing this helpful information and editing the question as well :) – Adham Enaya Nov 30 '15 at 12:35

score 3 · Answer 2 · answered Nov 30 '15 at 12:08

3

Java's ConcurrentLinkedQueue seems like your best bet for a FIFO ordered queue.

answered Nov 30 '15 at 12:08

Devexed

66
3

How do I share single list between two infinite loop threads?

2 Answers2