BlockingQueue ReentrantLock을 사용하여 구현

Question

연습을 위해 BlockingQueue를 직접 작성했습니다. 메서드에 synchronized 키워드를 사용하지 않으려 고합니다. 대신 ReentrantLock을 사용하고 싶습니다.

이 구현을 작성하는 가장 좋은 방법은 무엇입니까? 저는 Java 닌자가 아니며 누군가 제 코드의 오류를 정확하게 지적하고이를 구현하는 더 좋은 방법을 제안 할 수 있다면 크게 감사 할 것입니다.

public class MyBlockingQueue<T> { 

private Queue<T> queue; 
private AtomicInteger limit = new AtomicInteger(10); 
private Lock put_lock = new ReentrantLock(); 
private Lock take_lock = new ReentrantLock(); 
private Condition put_condition = put_lock.newCondition(); 
private Condition take_condition = take_lock.newCondition(); 

public MyBlockingQueue(AtomicInteger limit){ 
    queue = new LinkedList<T>(); 
    this.limit = limit; 
} 

public boolean put(T item) throws InterruptedException{ 
    put_lock.lockInterruptibly(); 
    try { 
     while(queue.size() == limit.get()) { 
      put_condition.await(); 
     } 
     put_condition.signal(); 
     queue.add(item); 
    } finally{ 
     put_lock.unlock(); 
    } 

    return true; 
} 

public T take() throws InterruptedException{ 
    take_lock.lockInterruptibly(); 
    try { 
     while (queue.size() == 0) { 
      take_condition.await(); 
     } 
     take_condition.signal(); 
     return queue.poll(); 
    } finally { 
     take_lock.unlock(); 
    } 
} 

감사합니다.

Answer 1

로직을 Blocking Queue의 open jdk 구현과 비교할 수 있습니다.

ArrayBlockingQueue

Btw..ArrayBlockingQueue 또한 내가 가장 좋은 방법은 JDK 소스를 읽고 생각 ReentrantLock와