在Java中,SynchronousQueue隊列是一種特殊的阻塞隊列,其主要特點是只能同時有一個元素在隊列中,當一個線程嘗試將一個元素放入隊列時,它會被阻塞,直到另一個線程嘗試從隊列中取出該元素。
要實現排隊功能,可以使用SynchronousQueue的offer()方法和take()方法來實現。
以下是一個簡單的示例代碼:
import java.util.concurrent.SynchronousQueue;
public class QueueExample {
private static SynchronousQueue<String> queue = new SynchronousQueue<>();
public static void main(String[] args) {
// 創建多個線程
for (int i = 0; i < 5; i++) {
Thread thread = new Thread(() -> {
try {
String name = Thread.currentThread().getName();
System.out.println(name + " 正在排隊...");
queue.offer(name); // 將線程名稱放入隊列
System.out.println(name + " 排隊成功,開始工作");
Thread.sleep(1000);
System.out.println(name + " 工作完成,離開隊列");
queue.take(); // 從隊列中取出線程名稱
} catch (InterruptedException e) {
e.printStackTrace();
}
});
thread.start();
}
}
}
在這個示例中,創建了5個線程,每個線程都會嘗試將自己的名稱放入隊列中,然后等待其他線程取出自己的名稱。當一個線程被阻塞時,其他線程會繼續執行,直到被阻塞的線程被喚醒。
注意,SynchronousQueue隊列不存儲元素,只是作為線程間通信的中介,因此在使用過程中要確保有其他線程來取出隊列中的元素,否則會導致線程一直阻塞。