ホームページ > Java > &#&チュートリアル > Javaマルチスレッド「待機・通知機構」

Javaマルチスレッド「待機・通知機構」

无忌哥哥
リリース: 2018-07-23 11:07:50
オリジナル
2125 人が閲覧しました

古典的なパラダイム:

待機側は次の原則に従います:

1. オブジェクトのロックを取得します。
2. 条件が満たされない場合は、オブジェクトの wait() メソッドを呼び出し、通知後に条件を確認します。
3. 条件が満たされると、対応する論理タスクが実行されます。
疑似コードは次のとおりです:

synchronized(对象) { 
        while(条件不满足) { 
            对象.wait(); 
        } 
        完成任务逻辑 
     }
ログイン後にコピー

通知側は次の原則に従います:
1. オブジェクトのロックを取得します。
2. 条件を変更します。
3. オブジェクトを待機しているすべてのスレッドに通知します。
疑似コードは次のとおりです:

  • synchronized(对象) { 
    
            改变对象 
    
            对象.notifyAll(); 
    
        }
    ログイン後にコピー

サンプルコード:

import java.text.SimpleDateFormat;import java.util.Date;/**
 * 线程等待/通知机制
 * Created by peng on 2018/7/22.
 */public class WaitNotify {

    private static boolean flag = true;    private static Object lock = new Object();    public static void main(String[] args) {
        Thread waitThread = new Thread(new Wait(), "WaitThread");
        waitThread.start();
        SleepUtils.second(1);

        Thread notifyThread = new Thread(new Notify(), "NotifyThread");
        notifyThread.start();
    }    private static class Wait implements Runnable {
        @Override
        public void run() {            // 加锁,拥有lock的Monitor
            synchronized (lock) {                // 当条件不满足时,继续wait,同时释放了lock的锁
                while (flag) {                    
                try {
                        System.out.println(Thread.currentThread() + " flag is true. wait @ "
                                + new SimpleDateFormat("HH:mm:ss").format(new Date()));
                        lock.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }                // 条件满足时,完成工作
                System.out.println(Thread.currentThread() + " flag is false. running @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
            }
        }
    }    
    private static class Notify implements Runnable {
        @Override
        public void run() {            // 加锁,拥有lock的Monitor
            synchronized (lock) {
                System.out.println(Thread.currentThread() + " hold lock. notify @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
                lock.notifyAll();
                flag = false;
                SleepUtils.second(5);
            }            // 再次加锁
            synchronized (lock) {
                System.out.println(Thread.currentThread() + " hold lock again. sleep @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
                SleepUtils.second(5);
            }
        }
    }
}
ログイン後にコピー

以上がJavaマルチスレッド「待機・通知機構」の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

関連ラベル:
ソース:php.cn
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート