java父子线程之间实现共享传递数据

public class ThreadLocalExample {
    public static void main(String[] args) {
        // 定义 ThreadLocal 变量
        ThreadLocal<String> threadLocal = new ThreadLocal<>();

        // 在主线程中设置值
        threadLocal.set("主线程的值");

        // 创建子线程
        Thread childThread = new Thread(() -> {
            // 在子线程中通过 get 方法获取值
            String value = threadLocal.get();
            System.out.println("子线程获取的值：" + value);
        });
        childThread.start();
    }
}

import java.util.concurrent.ConcurrentHashMap;

public class ConcurrentMapExample {
    public static void main(String[] args) {
        // 定义 ConcurrentHashMap
        ConcurrentHashMap<String, String> concurrentMap = new ConcurrentHashMap<>();

        // 在主线程中设置值
        concurrentMap.put("key", "主线程的值");

        // 创建子线程
        Thread childThread = new Thread(() -> {
            // 在子线程中获取值
            String value = concurrentMap.get("key");
            System.out.println("子线程获取的值：" + value);
        });
        childThread.start();
    }
}

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class QueueExample {
    public static void main(String[] args) throws InterruptedException {
        // 定义阻塞队列
        BlockingQueue<String> blockingQueue = new LinkedBlockingQueue<>();

        // 在主线程中放入数据
        blockingQueue.put("主线程的值");

        // 创建子线程
        Thread childThread = new Thread(() -> {
            try {
                // 在子线程中获取数据
                String value = blockingQueue.take();
                System.out.println("子线程获取的值：" + value);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });
        childThread.start();
    }
}