Java의 `wait()` 및 `notify()` 메서드는 차단 대기열을 어떻게 구현합니까?

Java의 wait() 및 inform(): 대기열을 사용한 간단한 시나리오

Java에서 wait() 및 inform() 메소드는 스레드 동기화를 위한 메커니즘을 제공합니다. 이러한 메소드를 사용하여 차단 대기열을 구현할 수 있는 간단한 시나리오를 살펴보겠습니다.

차단 대기열 구현

차단 대기열은 다음과 같은 경우 스레드를 차단하는 대기열 데이터 구조입니다. 특정 조건이 충족되지 않으면 특정 작업을 수행하려고 합니다. 구현에서는 대기열이 가득 차거나 비어 있으면 각각 차단하는 put() 및 take() 메서드를 구현합니다.

public class BlockingQueue<T> {

    private Queue<T> queue = new LinkedList<>();
    private int capacity;

    public BlockingQueue(int capacity) {
        this.capacity = capacity;
    }

    // Blocks if the queue is full (no space to insert)
    public synchronized void put(T element) throws InterruptedException {
        while (queue.size() == capacity) {
            wait();
        }

        queue.add(element);
        notifyAll();
    }

    // Blocks if the queue is empty (nothing to remove)
    public synchronized T take() throws InterruptedException {
        while (queue.isEmpty()) {
            wait();
        }

        T item = queue.remove();
        notifyAll();
        return item;
    }
}

사용 방법

이제 이 차단 대기열을 사용하는 방법을 살펴보겠습니다.

BlockingQueue<Integer> queue = new BlockingQueue<>(10);

// Producer thread: adds elements to the queue
new Thread(() -> {
    for (int i = 0; i < 15; i++) {
        try {
            queue.put(i);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}).start();

// Consumer thread: retrieves elements from the queue
new Thread(() -> {
    for (int i = 0; i < 15; i++) {
        try {
            System.out.println(queue.take());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}).start();

이 예에서 생산자 스레드는 요소를 추가합니다. 대기열이 용량 제한에 도달하면 차단됩니다. 소비자 스레드는 요소를 검색하고 대기열이 비어 있으면 차단합니다.

주요 고려 사항

• 동기화된 블록 사용: wait() 스레드 안전을 보장하고 누락을 방지하려면 동기화된 블록 내에서 통지()를 사용해야 합니다. 신호.
• while 루프 사용: 잘못된 웨이크업(스레드가 알림을 받지 않고 다시 활성화되는 경우)으로 인한 조건을 확인하려면 while 루프를 사용하세요.
• Java 1.5 동시성 라이브러리 고려: Java 1.5는 더 높은 수준의 추상화 기능을 갖춘 동시성 라이브러리를 도입했습니다. (예: 잠금 및 조건) 더욱 깔끔하고 다양한 접근 방식을 제공합니다.

위 내용은 Java의 `wait()` 및 `notify()` 메서드는 차단 대기열을 어떻게 구현합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!