非同期スレッドにメッセージを発行する方法

2年 ago
桜, 春樹
1 minute

非同期スレッドに情報を渡す方法はJavaでは次のとおりです。

  1. 共有変数の利用：共有変数を定義し、メインスレッドと非同期スレッド間で読み書きする。メインスレッドは共有変数に情報を書き込み、非同期スレッドは共有変数から情報を取得する。

例えばnativ

public class Main {
private static String message;
public static void main(String[] args) throws InterruptedException {
Thread asyncThread = new Thread(() -> {
while (message == null) {
// 等待主线程写入信息
}
System.out.println("异步线程接收到信息：" + message);
});
asyncThread.start();
// 主线程写入信息
message = "Hello World";
asyncThread.join();
}
}
  1. コールバック関数を利用可能：インターフェイスを定義し、非同期スレッドはタスク完了時にインターフェイスのメソッドを呼び出し、情報を引数としてメインスレッドに渡すことが可能。

例えば、

public class Main {
public interface Callback {
void onCompleted(String message);
}
public static void main(String[] args) throws InterruptedException {
Thread asyncThread = new Thread(() -> {
// 异步任务完成后调用回调函数
String message = "Hello World";
callback.onCompleted(message);
});
asyncThread.start();
asyncThread.join();
}
}
  1. マルチスレッド間の通信機構を用いる：Java が提供する wait/notify や Condition といったマルチスレッド間の通信機構を利用し、メインスレッドが共有オブジェクトに情報を書き込み、非同期スレッドは通知を待機することで情報を取得する。

例えば

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Main {
private static String message;
private static final Lock lock = new ReentrantLock();
private static final Condition condition = lock.newCondition();
public static void main(String[] args) throws InterruptedException {
Thread asyncThread = new Thread(() -> {
lock.lock();
try {
while (message == null) {
// 等待主线程写入信息
condition.await();
}
System.out.println("异步线程接收到信息：" + message);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
});
asyncThread.start();
// 主线程写入信息
lock.lock();
try {
message = "Hello World";
condition.signal();
} finally {
lock.unlock();
}
asyncThread.join();
}
}

非同期スレッドに情報を渡す一般的な方法は上記の通りであり、具体的な使用方法は要件やシナリオによって異なります。

bannerAds