wait()/notify()方法

await()/signal()方法

BlockingQueue阻塞隊列方法

PipedInputStream/PipedOutputStream

阻塞隊列的一個簡單實現：

public class BlockingQueue {

private List queue = new LinkedList();

private int ?limit = 10;

public BlockingQueue(int limit){

this.limit = limit;

}

public synchronized void enqueue(Object item)throws InterruptedException ?{

while(this.queue.size() == this.limit) {

wait();

}

if(this.queue.size() == 0) {

notifyAll();

}

this.queue.add(item);

}

public synchronized Object dequeue() ?throws InterruptedException{

while(this.queue.size() == 0){

wait();

}

if(this.queue.size() == this.limit){

notifyAll();

}

return this.queue.remove(0);

}}

在enqueue和dequeue方法內部，只有隊列的大小等于上限(limit)或者下限(0)時，才調用notifyAll方法。如果隊列的大小既不等于上限，也不等于下限，任何線程調用enqueue或者dequeue方法時，都不會阻塞，都能夠正常的往隊列中添加或者移除元素。

wait()/notify()方法

生產者的主要作用是生成一定量的數據放到緩沖區中，然后重復此過程。與此同時，消費者也在緩沖區消耗這些數據。該問題的關鍵就是要保證生產者不會在緩沖區滿時加入數據，消費者也不會在緩沖區中空時消耗數據。

要解決該問題，就必須讓生產者在緩沖區滿時休眠(要么干脆就放棄數據)，等到下次消費者消耗緩沖區中的數據的時候，生產者才能被喚醒，開始往緩沖區添加數據。同樣，也可以讓消費者在緩沖區空時進入休眠，等到生產者往緩沖區添加數據之后，再喚醒消費者。

總結

以上是生活随笔為你收集整理的java 多线程的同步问题_java多线程解决同步问题的几种方式，原理和代码的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。