中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

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
读书| 铅山县| 天镇县| 喜德县| 德惠市| 修武县| 阿巴嘎旗| 逊克县| 盱眙县| 宜春市| 东宁县| 霸州市| 杭州市| 始兴县| 酒泉市| 土默特右旗| 清河县| 桐乡市| 进贤县| 凤阳县| 宜阳县| 绍兴县| 金湖县| 宁晋县| 黄大仙区| 宝坻区| 花莲县| 会宁县| 曲阳县| 双流县| 思茅市| 阳江市| 额尔古纳市| 全椒县| 海口市| 金昌市| 民县| 微博| 启东市| 滕州市| 宣汉县|