阅读量:1
在Java中，可以使用以下几种方式向异步线程传递信息：
- 使用共享变量：可以定义一个共享变量，在主线程和异步线程之间进行读写操作。主线程将信息写入共享变量，异步线程读取共享变量获取信息。
例如：
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(); } } - 使用回调函数：可以定义一个接口，异步线程在完成任务后调用接口的方法，将信息作为参数传递给主线程。
例如：
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(); } } - 使用线程间通信机制：可以使用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(); } } 以上是几种常见的向异步线程传递信息的方式，具体使用哪种方式取决于具体的需求和场景。
