package devmanuals.com;

import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;

class RemoveObject implements Runnable {
	BlockingDeque<Integer> bdq;
	String name;

	public RemoveObject(String name, BlockingDeque<Integer> bdq) {
		this.bdq = bdq;
		this.name = name;
	}

	public void run() {
		int i;
		System.out.println(name + " inserted the element into the deque");
		for (i = 0; i < 5; i++) {
			bdq.add(i);
			System.out.println(i);
			try {
				Thread.sleep(400);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		bdq.add(3);
		System.out.println(name
				+ " adds the new element into the deque then new deque = "
				+ bdq);
		System.out.println("Size of deque = " + bdq.size());
		bdq.remove(3);
		System.out
				.println("Remaining element of deque after removing the "
						+"\n first occurrence of '3' = "+ bdq);
	}
}

class RemoveObject1 implements Runnable {
	String name;
	BlockingDeque<Integer> bdq;

	public RemoveObject1(String name, BlockingDeque<Integer> bdq) {
		this.bdq = bdq;
		this.name = name;
		// new Thread().start();
	}

	public void run() {
		try {
			bdq.remove();
			Thread.sleep(1500);
			System.out.println(name
					+ " deleted the first element then remaining deque = "
					+ bdq);
			System.out.println("Size of deque = " + bdq.size());
		} catch (InterruptedException e) {
			e.printStackTrace();
		}

	}
}

public class BdqRemoveObject {
	public static void main(String args[]) {
		BlockingDeque<Integer> bdq = new LinkedBlockingDeque<Integer>(5);
		Runnable a = new RemoveObject("A", bdq);
		new Thread(a).start();
		try {
			Thread.sleep(400);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		Runnable b = new RemoveObject1("B", bdq);
		new Thread(b).start();
	}

}