algorithm/BlockingQueue/src/BlockingQueue.java at master · wodgithub/algorithm · GitHub

Repository navigation

Code
Pull requests
Actions
Projects
Wiki
Security and quality
Insights

History

import java.util.LinkedList;

import java.util.Queue;

public class BlockingQueue<T> {

private int maxSize;

private Queue<T> queue;

public BlockingQueue(int size) {

maxSize = size;

queue = new LinkedList<T>();

}

public synchronized T dequeue() {

while (queue.isEmpty()) {

try {

wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

T value = queue.poll();

notifyAll();

return value;

}

public synchronized void enqueue(T value) {

while (queue.size() == maxSize) {

try {

wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

queue.add(value);

notifyAll();

}

public static void main(String[] args) throws Exception{

BlockingQueue<String> queue = new BlockingQueue<String>(2);

Producer producer = new Producer(queue);

Consumer consumer = new Consumer(queue);

new Thread(producer).start();

new Thread(consumer).start();

Thread.sleep(400);

}

algorithm/BlockingQueue/src/BlockingQueue.java at master · wodgithub/algorithm · GitHub

Repository navigation

Expand file tree

Breadcrumbs

BlockingQueue.java

Latest commit

History

Breadcrumbs

BlockingQueue.java

File metadata and controls