Java マルチスレッドでのスレッド間の通信
一、使用while方式来实现线程之间的通信
package com.ietree.multithread.sync;import java.util.ArrayList;import java.util.List;public class MyList {
private volatile static List list = new ArrayList(); public void add() {
list.add("apple");
} public int size() { return list.size();
} public static void main(String[] args) { final MyList list1 = new MyList();
Thread t1 = new Thread(new Runnable() {
@Override public void run() { try { for (int i = 0; i < 10; i++) {
list1.add();
System.out.println("当前线程：" + Thread.currentThread().getName() + "添加了一个元素..");
Thread.sleep(500);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "t1");
Thread t2 = new Thread(new Runnable() {
@Override public void run() { while (true) { if (list1.size() == 5) {
System.out.println("当前线程收到通知：" + Thread.currentThread().getName() + " list size = 5 线程停止.."); throw new RuntimeException();
}
}
}
}, "t2");
t1.start();
t2.start();
}
}程序输出：
当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. Exception in thread "t2" 当前线程收到通知：t2 list size = 5 线程停止.. java.lang.RuntimeException at com.ietree.multithread.sync.MyList$2.run(MyList.java:43) at java.lang.Thread.run(Unknown Source) 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素..
理解：线程Thread2不停地通过while语句检测这个条件(list.size()==5)是否成立 ，从而实现了线程间的通信。但是这种方式会浪费CPU资源。
二、wait notfiy 方法实现多线程中线程之间的通信
使用这种方式实现线程通信需要注意：wait和notify必须配合synchronized关键字使用，wait方法释放锁，notify方法不释放锁。并且在这个例子中必须是Thread2先执行才可以。
List list = "apple" ListAdd2 list2 = Object lock = = Thread( ( i = 0; i < 10; i++"当前线程：" + Thread.currentThread().getName() + "添加了一个元素.."500 (list2.size() == 5"已经发出通知..""t1"= Thread( (list2.size() != 5"当前线程：" + Thread.currentThread().getName() + "收到通知线程停止.." "t2"
程序输出：
当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 已经发出通知.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t2收到通知线程停止.. Exception in thread "t2" java.lang.RuntimeException at com.ietree.multithread.sync.ListAdd3$2.run(ListAdd3.java:59) at java.lang.Thread.run(Unknown Source)
三、使用CountDownLatch类来实现多线程中线程之间的实时通信
package com.ietree.multithread.sync;import java.util.ArrayList;import java.util.List;import java.util.concurrent.CountDownLatch;public class ListAdd2 { private volatile static List list = new ArrayList(); public void add() {
list.add("apple");
} public int size() { return list.size();
} public static void main(String[] args) { final ListAdd2 list2 = new ListAdd2(); final CountDownLatch countDownLatch = new CountDownLatch(1);
Thread t1 = new Thread(new Runnable() {
@Override public void run() { try { for (int i = 0; i < 10; i++) {
list2.add();
System.out.println("当前线程：" + Thread.currentThread().getName() + "添加了一个元素..");
Thread.sleep(500); if (list2.size() == 5) {
System.out.println("已经发出通知..");
countDownLatch.countDown();
}
} // }
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "t1");
Thread t2 = new Thread(new Runnable() {
@Override public void run() { if (list2.size() != 5) { try {
countDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("当前线程：" + Thread.currentThread().getName() + "收到通知线程停止.."); throw new RuntimeException();
}
}, "t2");
t2.start();
t1.start();
}
}程序输出：
当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 已经发出通知.. Exception in thread "t2" 当前线程：t1添加了一个元素.. 当前线程：t2收到通知线程停止.. java.lang.RuntimeException at com.ietree.multithread.sync.ListAdd2$2.run(ListAdd2.java:56) at java.lang.Thread.run(Unknown Source) 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素.. 当前线程：t1添加了一个元素..
以上がJava マルチスレッドでのスレッド間の通信の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
AI Hentai Generator
AIヘンタイを無料で生成します。
人気の記事
ホットツール
メモ帳++7.3.1
使いやすく無料のコードエディター
SublimeText3 中国語版
中国語版、とても使いやすい
ゼンドスタジオ 13.0.1
強力な PHP 統合開発環境
ドリームウィーバー CS6
ビジュアル Web 開発ツール
SublimeText3 Mac版
神レベルのコード編集ソフト（SublimeText3）
ホットトピック
7569
15
1386
52
87
11
28
107
ジャワのウェカ
Aug 30, 2024 pm 04:28 PM
Java の Weka へのガイド。ここでは、weka java の概要、使い方、プラットフォームの種類、利点について例を交えて説明します。
Java Springのインタビューの質問
Aug 30, 2024 pm 04:29 PM
この記事では、Java Spring の面接で最もよく聞かれる質問とその詳細な回答をまとめました。面接を突破できるように。
Java 8 Stream Foreachから休憩または戻ってきますか？
Feb 07, 2025 pm 12:09 PM
Java 8は、Stream APIを導入し、データ収集を処理する強力で表現力のある方法を提供します。ただし、ストリームを使用する際の一般的な質問は次のとおりです。 従来のループにより、早期の中断やリターンが可能になりますが、StreamのForeachメソッドはこの方法を直接サポートしていません。この記事では、理由を説明し、ストリーム処理システムに早期終了を実装するための代替方法を調査します。 さらに読み取り：JavaストリームAPIの改善 ストリームを理解してください Foreachメソッドは、ストリーム内の各要素で1つの操作を実行する端末操作です。その設計意図はです
Java での日付までのタイムスタンプ
Aug 30, 2024 pm 04:28 PM
Java での日付までのタイムスタンプに関するガイド。ここでは、Java でタイムスタンプを日付に変換する方法とその概要について、例とともに説明します。
カプセルの量を見つけるためのJavaプログラム
Feb 07, 2025 am 11:37 AM
カプセルは3次元の幾何学的図形で、両端にシリンダーと半球で構成されています。カプセルの体積は、シリンダーの体積と両端に半球の体積を追加することで計算できます。このチュートリアルでは、さまざまな方法を使用して、Javaの特定のカプセルの体積を計算する方法について説明します。 カプセルボリュームフォーミュラ カプセルボリュームの式は次のとおりです。 カプセル体積=円筒形の体積2つの半球体積 で、 R：半球の半径。 H：シリンダーの高さ（半球を除く）。 例1 入力 RADIUS = 5ユニット 高さ= 10単位 出力 ボリューム= 1570.8立方ユニット 説明する 式を使用してボリュームを計算します。 ボリューム=π×R2×H（4
Spring Tool Suiteで最初のSpring Bootアプリケーションを実行するにはどうすればよいですか？
Feb 07, 2025 pm 12:11 PM
Spring Bootは、Java開発に革命をもたらす堅牢でスケーラブルな、生産対応のJavaアプリケーションの作成を簡素化します。 スプリングエコシステムに固有の「構成に関する慣習」アプローチは、手動のセットアップを最小化します。
