亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

Java SyncContainerHb類使用實例

小億
74
2023-12-19 04:33:55
欄目: 編程語言

以下是一個使用SyncContainerHb類的Java示例:

import java.util.concurrent.TimeUnit;

public class SyncContainerHbExample {
  
    public static void main(String[] args) {
        SyncContainerHb<String> container = new SyncContainerHb<>();
        
        Thread producerThread = new Thread(() -> {
            try {
                container.put("Hello");
                container.put("World");
                container.put("!");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        
        Thread consumerThread = new Thread(() -> {
            try {
                TimeUnit.SECONDS.sleep(2); // 等待2秒
                System.out.println(container.get());
                System.out.println(container.get());
                System.out.println(container.get());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        
        producerThread.start();
        consumerThread.start();
    }
}

在這個例子中,我們創建了一個SyncContainerHb對象,并在生產者線程中放置了三個字符串。然后,在消費者線程中,我們等待2秒后從容器中獲取這三個字符串,并打印輸出它們。

SyncContainerHb類的實現如下:

import java.util.LinkedList;
import java.util.Queue;

public class SyncContainerHb<T> {
  
    private Queue<T> container = new LinkedList<>();
  
    public synchronized void put(T element) throws InterruptedException {
        while (container.size() >= 1) {
            wait(); // 如果容器已滿,則等待
        }
        container.offer(element);
        notifyAll(); // 通知其他線程可以從容器中獲取元素了
    }
  
    public synchronized T get() throws InterruptedException {
        while (container.isEmpty()) {
            wait(); // 如果容器為空,則等待
        }
        T element = container.poll();
        notifyAll(); // 通知其他線程可以向容器中放置新元素了
        return element;
    }
}

SyncContainerHb類使用了Java的內置對象監視器(Intrinsic Locks)來實現同步。容器使用LinkedList來存儲元素,并通過synchronized關鍵字來保證在放置和獲取元素時的線程安全性。在put()方法和get()方法中,使用wait()方法來暫停線程的執行,直到某個條件滿足。當容器已滿時,生產者線程會調用wait()方法等待,直到消費者線程從容器中獲取了一個元素并調用notifyAll()方法喚醒它;當容器為空時,消費者線程會調用wait()方法等待,直到生產者線程放置了一個元素并調用notifyAll()方法喚醒它。這樣,生產者和消費者線程就可以安全地共享容器了。

0
邢台市| 阜新| 望都县| 内黄县| 平顶山市| 高唐县| 漠河县| 塘沽区| 巴里| 大城县| 屏边| 麻江县| 四会市| 馆陶县| 陆丰市| 墨玉县| 长兴县| 玛曲县| 浙江省| 阳原县| 逊克县| 江北区| 双城市| 驻马店市| 东源县| 金川县| 高清| 饶阳县| 岫岩| 塔城市| 工布江达县| 威信县| 泸州市| 威海市| 嵊州市| 永济市| 织金县| 东至县| 溧水县| 海原县| 修水县|