Java でのマルチスレッドアプリケーションの作成: 総合ガイド-＆＃＆チュートリアル-php.cn

Java でのマルチスレッドアプリケーションの作成: 総合ガイド

王林

リリース： 2024-09-12 14:18:02

オリジナル

1137 人が閲覧しました

Writing Multi-threaded Applications in Java: A Comprehensive Guide

ソフトウェア開発の世界では、効率とスピードが最も重要です。アプリケーションが複雑になり、処理する必要があるデータの量が増加するにつれて、最新のマルチコアプロセッサの機能を活用することが不可欠になります。ここで Java の同時実行機能が活躍し、開発者が複数のタスクを同時に実行できるマルチスレッドアプリケーションを作成できるようになり、パフォーマンスが大幅に向上します。

Java 同時実行性を理解する

Java の同時実行性は、複数のタスクを並行して実行できるアプリケーションの開発を容易にするフレームワークです。これは、複数のスレッドまたは実行単位を実行することによって実現され、個別のプロセスよりも軽量で管理しやすくなります。

Java は、開発者が堅牢でスケーラブルなマルチスレッドアプリケーションを実装できるように設計された、java.util.concurrent パッケージで豊富なツールと API のセットを提供します。これらのツールは、基本的なスレッド管理から、より高度な同期メカニズムや同時データ構造に至るまで、同時実行のさまざまな側面を処理するように設計されています。

Java のスレッドの基礎

スレッドは、Java アプリケーションの基本的な実行単位です。 Java スレッドは、Runnable インターフェイスを実装するか、Thread クラスを拡張することによって作成できます。

1.実行可能インターフェイスの実装:

public class HelloRunnable implements Runnable {
    public void run() {
        System.out.println("Hello from a thread!");
    }

    public static void main(String[] args) {
        Thread thread = new Thread(new HelloRunnable());
        thread.start();
    }
}

ログイン後にコピー

2.スレッドクラスの拡張:

public class HelloThread extends Thread {
    public void run() {
        System.out.println("Hello from a thread!");
    }

    public static void main(String[] args) {
        HelloThread thread = new HelloThread();
        thread.start();
    }
}

ログイン後にコピー

どちらの例でも、run() メソッドはスレッドによって実行されるコードを定義し、start() メソッドはスレッドの実行を開始するために使用されます。

同期とスレッドセーフ

リソースを共有するときにスレッドが相互に干渉しないようにするには、同期が重要です。 Java は、いくつかの同期メカニズムを提供します。

1.同期メソッド:
メソッドを同期済みとして定義すると、メソッドが完了するまで、そのメソッドを実行するスレッドのオブジェクトがロックされます。

public synchronized void increment() {
    this.count++;
}

ログイン後にコピー

2.同期ブロック:
Java では、メソッド全体を同期する代わりに、メソッド内のコードブロックを同期できます。

public void add(int value) {
    synchronized(this) {
        this.count += value;
    }
}

ログイン後にコピー

3. java.util.concurrent.locks パッケージ内のロック:
Java は、Lock インターフェースを通じてより高度なロックメカニズムを提供し、同期されたメソッドやブロックよりも高い柔軟性を提供します。

Lock lock = new ReentrantLock();

public void safeIncrement() {
    lock.lock();
    try {
        count++;
    } finally {
        lock.unlock();
    }
}

ログイン後にコピー

高度な同時実行ツール

Java の高度な同時実行ツールは、パフォーマンスを犠牲にすることなく、さまざまな複雑な同期の問題に対処します。

1.同時コレクション:
Java は、マルチスレッド環境でのデータ管理に役立つ、ConcurrentHashMap、CopyOnWriteArrayList、BlockingQueue などの標準コレクションのスレッドセーフなバリアントを提供します。

2.エグゼキューターフレームワーク:
このフレームワークは、スレッドのプールを使用して非同期モードでのタスクの実行を簡素化します。

ExecutorService executor = Executors.newFixedThreadPool(10);
executor.execute(new HelloRunnable());
executor.shutdown();

ログイン後にコピー

3.将来および呼び出し可能:
Callable インターフェイスは Runnable に似ていますが、結果を返すことができます。 Future は Callable によって提供された結果を保持し、タスクが完了したかどうかを確認できます。

Callable<Integer> task = () -> {
    return 123;
};
Future<Integer> future = executor.submit(task);
Integer result = future.get();  // This line blocks until the result is available.

ログイン後にコピー

4.フォーク/結合フレームワーク:
Java 7 で導入されたこのフレームワークは、より小さな部分に分割し、それらの部分を組み合わせた結果を処理できるように設計されています。

class MyRecursiveTask extends RecursiveTask<Long> {
    @Override
    protected Long compute() {
        // divide task, fork new tasks, join results
    }
}

ログイン後にコピー

同時実行のベストプラクティス

共有リソースを最小限に抑える: スレッド内でデータをできるだけカプセル化したままにするようにします。
wait() や Notify() よりも同時実行ユーティリティを優先します: 新しい Java 同時実行ユーティリティでは、より詳細な制御が提供され、エラーが発生しにくくなります。
不変オブジェクトを使用する: 不変オブジェクトは本来スレッドセーフであり、同期せずにスレッド間で自由に共有できます。