検索
ホームページJava&#&チュートリアルJava でのマルチスレッド同期のための CountDownLatch のコード共有例

この記事では、主にマルチスレッド同期のためのJavaのCountDownLatchの詳細な説明とサンプルコードを紹介します。必要な友人はそれを参照してください

JavaのCountDownLatchのマルチスレッド同期の詳細な説明

CountDownLatchの紹介

前回の Java 学習ノートでは、Java でのマルチスレッド同期のいくつかの方法をまとめました:

1、synchronized 同期キーワード。
2. ロック インターフェース とその実装クラス ReentrantLock、ReadWriteLock ロックは同期を実現します。
3. セマフォは同期を実現します。

その中で、synchronized キーワードと Lock ロックは、複数のスレッドによる同じリソースへの同時アクセスの問題を解決します。セマフォは、リソースの複数のコピーへの共有アクセスの問題を解決します。

今日は、Java の別のマルチスレッド同期補助クラス、CountDownLatch について学びましょう。公式ドキュメントでは、CountDownLatch を次のように説明しています。これにより、1 つ以上のスレッドが、他のスレッドで実行されている一連の操作が完了するまで待機できるようになります。つまり、CountDownLatch は 1 つ以上のスレッドを制御し、開始する前に複数のスレッドが特定のタスクを完了するまで待機させます。 CountDownLatch は主に、複数のタスクの実行を同期するために使用され、共有リソースの同期に使用される他の同期キーワード、ロック、セマフォとは異なります。

CountDownLatch の実装原理の紹介:

CountDownLatch は、内部的にカウンターを維持します。カウンターの値は、完了するタスクの数 N です。スレッドは、これらの N タスクの完了を待機する必要があります。

CountDownLatchのawait()メソッドを呼び出して自身をスリープ待機状態にします。

タスクスレッドはタスクが完了すると、CountDownLatchのcountDown()メソッドを呼び出してタスクが完了したことを示します。このとき、CountDownLatchのカウンタ値は1減ります。すべてのタスクが完了すると、カウンタ値が0です。カウンタ値が 0 の場合、CountDownLatch は、await() メソッドによってスリープ状態になったすべてのスレッドをウェイクアップします。

CountDownLatch の使用法:

CountDownLatch を使用するには、主に 3 つのポイントがあります:

1. 初期化中に、完了を待機しているタスクの数を指定する必要があります。

2. 特定のタスクが完了したら、CountDownLatch の countDown() メソッドを呼び出し、そのタスクが完了したことを CountDownLatch に報告します。

3. タスクの完了を待つ必要があるスレッドは、 CountDownLatch の await() メソッドの呼び出し後、スレッドはスリープ状態に入り、すべてのタスクが完了して CountDownLatch のカウンタ値が 0 に達すると、await() メソッドによってスリープしていたスレッドが目覚めます。

ここでは、CountDownLatch の使用方法の詳細を示すために、Java 7 同時プログラミング実践マニュアルの CountDownLatch の使用例に基づいていくつかの改良を加えました。

会議では、10 人の参加者と主催者をシミュレートします。他の参加者が会議を開始して発言できるようになるまで、サインインを待ちます。これを行うには、まず、管理対象となるクラス VideoConference を作成します。このクラスは、参加者がチェックインするために呼び出すことのできる、arrivy() メソッドを提供します。会議管理の所有者はホストであり、各参加者がサインインするのを待ちます:

public class VideoConference implements Runnable{ 
  private final CountDownLatch countDownLatch; 
  private int number; 
  public VideoConference(int number) { 
    this.number = number; 
    this.countDownLatch = new CountDownLatch(number);//使用Number初始化其内部的计数器,当初始化完成后,不能再次初始化 
  } 
  public void arrive(String name){ 
    //每个需要同步的任务,在任务完成时,需要调用该方法 
    countDownLatch.countDown();//countDownLatch内部的计数器减1 
    System.out.print("arrive:"+name+"\n"); 
    try{ 
      countDownLatch.await();//await方法是线程进入休眠,当countDownLatch计数器为0时,将被唤醒 
      //线程被唤醒,在这里可以执行一系列任务 
      System.out.print("name:"+name + " say:let's start..." +"\n"); 
    }catch (InterruptedException e){ 
      e.printStackTrace(); 
    } 
  } 
  public void run(){ 
    System.out.print("has arrive:"+(number-countDownLatch.getCount())+"\n"); 
    try{ 
      countDownLatch.await();//await方法是线程进入休眠,当countDownLatch计数器为0时,将被唤醒 
      //线程被唤醒,在这里可以执行一系列任务 
      System.out.print("all arrived:"+(number-countDownLatch.getCount())+"\n"); 
    }catch (InterruptedException e){ 
      e.printStackTrace(); 
    } 
  } 
}

参加者クラスを作成します 参加者:

public class Participant implements Runnable{ 
  private VideoConference videoConference; 
  private String name; 
 
  public Participant(String name, VideoConference videoConference) { 
    this.name = name; 
    this.videoConference = videoConference; 
  } 
  public void run(){ 
    try { 
      //do something 
      Thread.sleep(50); 
      // 
      videoConference.arrive(name); 
    }catch (InterruptedException e){ 
      e.printStackTrace(); 
    } 
  } 
 
  public static void main(String[] args){ 
    VideoConference videoConference = new VideoConference(10); 
    Thread videoThread = new Thread(videoConference); 
    videoThread.start(); 
    for(int i=0; i<10; i++){ 
      Thread thread = new Thread(new Participant("participant:"+i,videoConference)); 
      thread.start(); 
    } 
  } 
}

参加者クラスの主要な機能最初に 10 人の参加者が必要な会議を作成します その後, 10 人の参加者が作成され、1 人ずつサインインすると、各参加者とホストが「覚醒」して発言します。

概要:

CountDownLatch クラスは、マルチスレッド間の同期待ちとタスク調整の問題を解決します。たとえば、プログラムの main 関数を開始する前に、構成環境を完了する必要があります。チェック、ネットワーク チェックなど。複数のサブタスクと同様のシナリオ。 Java では、CountDownLatch を使用して複数のスレッド間の同期待機を実現するだけでなく、バ​​リア テクノロジ CyclicBarrier を使用して複数のスレッド間の同期待機とタスク調整を実現することもできます。

以上がJava でのマルチスレッド同期のための CountDownLatch のコード共有例の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
Javaのプラットフォームの独立性を脅かしたり強化したりする新しいテクノロジーはありますか?Javaのプラットフォームの独立性を脅かしたり強化したりする新しいテクノロジーはありますか?Apr 24, 2025 am 12:11 AM

新しいテクノロジーは、両方の脅威をもたらし、Javaのプラットフォームの独立性を高めます。 1)Dockerなどのクラウドコンピューティングとコンテナ化テクノロジーは、Javaのプラットフォームの独立性を強化しますが、さまざまなクラウド環境に適応するために最適化する必要があります。 2)WebAssemblyは、Graalvmを介してJavaコードをコンパイルし、プラットフォームの独立性を拡張しますが、パフォーマンスのために他の言語と競合する必要があります。

JVMのさまざまな実装は何ですか、そしてそれらはすべて同じレベルのプラットフォームの独立性を提供しますか?JVMのさまざまな実装は何ですか、そしてそれらはすべて同じレベルのプラットフォームの独立性を提供しますか?Apr 24, 2025 am 12:10 AM

JVMの実装が異なると、プラットフォームの独立性が得られますが、パフォーマンスはわずかに異なります。 1。OracleHotspotとOpenJDKJVMは、プラットフォームの独立性で同様に機能しますが、OpenJDKは追加の構成が必要になる場合があります。 2。IBMJ9JVMは、特定のオペレーティングシステムで最適化を実行します。 3. Graalvmは複数の言語をサポートし、追加の構成が必要です。 4。AzulzingJVMには、特定のプラットフォーム調整が必要です。

プラットフォームの独立性は、開発コストと時間をどのように削減しますか?プラットフォームの独立性は、開発コストと時間をどのように削減しますか?Apr 24, 2025 am 12:08 AM

プラットフォームの独立性により、開発コストが削減され、複数のオペレーティングシステムで同じコードセットを実行することで開発時間を短縮します。具体的には、次のように表示されます。1。開発時間を短縮すると、1セットのコードのみが必要です。 2。メンテナンスコストを削減し、テストプロセスを統合します。 3.展開プロセスを簡素化するための迅速な反復とチームコラボレーション。

Javaのプラットフォームの独立性は、コードの再利用をどのように促進しますか?Javaのプラットフォームの独立性は、コードの再利用をどのように促進しますか?Apr 24, 2025 am 12:05 AM

java'splatformentedencefacilitatesecodereusebyAllowingbyTeCodeCodeCodeCodeTorunonAnyPlatformm.1)DevelopersConcodeCodeOnceOnceOnconconsentEntentEntEntEntEntEntentPlatforms.2)維持化されたアスカデドは、NoeedReadedoesではありません

Javaアプリケーションのプラットフォーム固有の問題をどのようにトラブルシューティングしますか?Javaアプリケーションのプラットフォーム固有の問題をどのようにトラブルシューティングしますか?Apr 24, 2025 am 12:04 AM

Javaアプリケーションのプラットフォーム固有の問題を解決するには、次の手順を実行できます。1。Javaのシステムクラスを使用して、システムプロパティを表示して実行中の環境を理解します。 2。ファイルクラスまたはjava.nio.fileパッケージを使用して、ファイルパスを処理します。 3。オペレーティングシステムの条件に応じてローカルライブラリをロードします。 4. VisualVMまたはJProfilerを使用して、クロスプラットフォームのパフォーマンスを最適化します。 5.テスト環境が、Dockerコンテナ化を通じて生産環境と一致していることを確認してください。 6. githubactionsを使用して、複数のプラットフォームで自動テストを実行します。これらの方法は、Javaアプリケーションでプラットフォーム固有の問題を効果的に解決するのに役立ちます。

JVMのクラスローダーサブシステムは、プラットフォームの独立性にどのように貢献していますか?JVMのクラスローダーサブシステムは、プラットフォームの独立性にどのように貢献していますか?Apr 23, 2025 am 12:14 AM

クラスローダーは、統一されたクラスファイル形式、動的読み込み、親代表団モデル、プラットフォーム非依存バイトコードを通じて、さまざまなプラットフォーム上のJavaプログラムの一貫性と互換性を保証し、プラットフォームの独立性を実現します。

Javaコンパイラはプラットフォーム固有のコードを作成しますか?説明する。Javaコンパイラはプラットフォーム固有のコードを作成しますか?説明する。Apr 23, 2025 am 12:09 AM

Javaコンパイラによって生成されたコードはプラットフォームに依存しませんが、最終的に実行されるコードはプラットフォーム固有です。 1。Javaソースコードは、プラットフォームに依存しないバイトコードにコンパイルされます。 2。JVMは、特定のプラットフォームのバイトコードをマシンコードに変換し、クロスプラットフォーム操作を保証しますが、パフォーマンスは異なる場合があります。

JVMは、さまざまなオペレーティングシステムでマルチスレッドをどのように処理しますか?JVMは、さまざまなオペレーティングシステムでマルチスレッドをどのように処理しますか?Apr 23, 2025 am 12:07 AM

マルチスレッドは、プログラムの応答性とリソースの利用を改善し、複雑な同時タスクを処理できるため、最新のプログラミングで重要です。 JVMは、スレッドマッピング、スケジューリングメカニズム、同期ロックメカニズムを介して、異なるオペレーティングシステム上のマルチスレッドの一貫性と効率を保証します。

See all articles

ホットAIツール

Undresser.AI Undress

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

Undress AI Tool

脱衣画像を無料で

Clothoff.io

Clothoff.io

AI衣類リムーバー

Video Face Swap

Video Face Swap

完全無料の AI 顔交換ツールを使用して、あらゆるビデオの顔を簡単に交換できます。

ホットツール

メモ帳++7.3.1

メモ帳++7.3.1

使いやすく無料のコードエディター

AtomエディタMac版ダウンロード

AtomエディタMac版ダウンロード

最も人気のあるオープンソースエディター

MinGW - Minimalist GNU for Windows

MinGW - Minimalist GNU for Windows

このプロジェクトは osdn.net/projects/mingw に移行中です。引き続きそこでフォローしていただけます。 MinGW: GNU Compiler Collection (GCC) のネイティブ Windows ポートであり、ネイティブ Windows アプリケーションを構築するための自由に配布可能なインポート ライブラリとヘッダー ファイルであり、C99 機能をサポートする MSVC ランタイムの拡張機能が含まれています。すべての MinGW ソフトウェアは 64 ビット Windows プラットフォームで実行できます。

ゼンドスタジオ 13.0.1

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

WebStorm Mac版

WebStorm Mac版

便利なJavaScript開発ツール