작성
·
77
0
public class BoundedQueueV4 implements BoundedQueue {
private final Lock lock = new ReentrantLock();
private final Condition condition = lock.newCondition();
private final Queue<String> queue = new ArrayDeque<>();
private final int max;
public BoundedQueueV4(int max) {
this.max = max;
}
@Override
public void put(String data) {
lock.lock();
try {
while (queue.size() == max) {
log("[put] 큐가 가득 참, 생산자 대기");
try {
condition.await();
log("[put] 생산자 깨어남");
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
queue.offer(data);
log("[put] 생산자 데이터 저장, notify() 호출");
condition.signal();
} finally {
lock.unlock();
}
}
@Override
public String take() {
lock.lock();
try {
while (queue.isEmpty()) {
log("[take] 큐에 데이터가 없음, 소비자 대기");
try {
condition.await();
log("[take] 소비자 깨어남");
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
String data = queue.poll();
log("[take] 소비자 데이터 획득, notify() 호출");
condition.signal();
return data;
} finally {
lock.unlock();
}
}
@Override
public String toString() {
return queue.toString();
}
}
synchronized를 사용 했을때는 객체가 기본적으로 가지고 있는 락과 스레드 대기 공간을 사용하는거 같습니다. 궁금한점은 ReentrantLock 객체를 생성하고 Condition 객체를 생성하면 BoundedQueueV4 내부에 또 다른 락과 스레드 대기 공간이 생성 되는건가요?
답변 2
0
0
안녕하세요, 인프런 AI 인턴입니다. 감바스님.
ReentrantLock과 Condition에 대해 질문해 주셔서 감사합니다. 관련된 질문과 답변을 찾아보았는데, 이에 대한 답변이 있는 유사한 질문들을 일부 확인할 수 있었습니다. 따라서 간단한 설명과 함께 관련 자료를 안내해드리겠습니다.
ReentrantLock과 Condition을 사용하면, synchronized 및 wait/notify 메커니즘을 사용하는 것과 약간 다른 방식으로 동작하게 됩니다. 아래 예시를 통해 설명드리겠습니다.
ReentrantLock:
Condition:
이제 구체적인 기존 답변을 참고해 보시면 도움이 될 것 같습니다:
관련해서는 강의에서도 다루어진 내용이니 참고해 보시면 더 많은 정보를 얻으실 수 있습니다.
저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다.
현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏
추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.