import java.util.concurrent.ConcurrentLinkedDeque;

public class ConcurrentCollectionExample {

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

        // 創(chuàng)建一個并發(fā)雙端隊列
        ConcurrentLinkedDeque<String> deque = new ConcurrentLinkedDeque<>();

        // 增加任務(wù)類，用于向隊列中添加數(shù)據(jù)
        class AddTask implements Runnable {
            private ConcurrentLinkedDeque<String> deque;

            public AddTask(ConcurrentLinkedDeque<String> deque) {
                this.deque = deque;
            }

            @Override
            public void run() {
                String name = Thread.currentThread().getName();
                for (int i = 0; i < 1000; i++) {
                    deque.add(name + ":" + i);
                }
            }
        }

        // 刪除任務(wù)類，用于從隊列中刪除數(shù)據(jù)
        class PollTask implements Runnable {
            private ConcurrentLinkedDeque<String> deque;

            public PollTask(ConcurrentLinkedDeque<String> deque) {
                this.deque = deque;
            }

            @Override
            public void run() {
                String name = Thread.currentThread().getName();
                while (!deque.isEmpty()) {
                    System.out.println(name + " removed: " + deque.poll());
                }
            }
        }

        // 創(chuàng)建并啟動添加數(shù)據(jù)的線程
        Thread addThread1 = new Thread(new AddTask(deque), "AddThread1");
        Thread addThread2 = new Thread(new AddTask(deque), "AddThread2");
        addThread1.start();
        addThread2.start();

        // 等待添加數(shù)據(jù)的線程完成
        addThread1.join();
        addThread2.join();

        // 創(chuàng)建并啟動刪除數(shù)據(jù)的線程
        Thread pollThread = new Thread(new PollTask(deque), "PollThread");
        pollThread.start();

        // 等待刪除數(shù)據(jù)的線程完成
        pollThread.join();

        System.out.println("Deque is now empty.");
    }
}