快捷導(dǎo)航

java父子線程之間實(shí)現(xiàn)共享傳遞數(shù)據(jù)

更新時(shí)間：2025年02月14日 11:34:37 作者：阿賈克斯的黎明

本文介紹了Java中父子線程間共享傳遞數(shù)據(jù)的幾種方法,包括ThreadLocal變量、并發(fā)集合和內(nèi)存隊(duì)列或消息隊(duì)列,并提醒注意并發(fā)安全問題

通過 ThreadLocal 變量共享數(shù)據(jù)

ThreadLocal是一個(gè)線程局部變量，它可以為每個(gè)線程提供獨(dú)立的變量副本。

以下是一個(gè)示例代碼：

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

        // 在主線程中設(shè)置值
        threadLocal.set("主線程的值");

        // 創(chuàng)建子線程
        Thread childThread = new Thread(() -> {
            // 在子線程中通過 get 方法獲取值
            String value = threadLocal.get();
            System.out.println("子線程獲取的值：" + value);
        });
        childThread.start();
    }
}

在上述代碼中，我們通過ThreadLocal變量在主線程和子線程之間共享數(shù)據(jù)。

在主線程中設(shè)置值后，子線程可以通過get方法獲取到相同的值。

通過并發(fā)集合共享數(shù)據(jù)

可以使用 Java 中的并發(fā)集合，如ConcurrentHashMap來實(shí)現(xiàn)父子線程間的數(shù)據(jù)共享。

以下是一個(gè)示例代碼：

import java.util.concurrent.ConcurrentHashMap;

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

        // 在主線程中設(shè)置值
        concurrentMap.put("key", "主線程的值");

        // 創(chuàng)建子線程
        Thread childThread = new Thread(() -> {
            // 在子線程中獲取值
            String value = concurrentMap.get("key");
            System.out.println("子線程獲取的值：" + value);
        });
        childThread.start();
    }
}

在這個(gè)例子中，我們使用ConcurrentHashMap在主線程和子線程之間共享數(shù)據(jù)。

在主線程中放入鍵值對(duì)后，子線程可以通過相同的鍵獲取到對(duì)應(yīng)的值。

通過內(nèi)存隊(duì)列或消息隊(duì)列共享數(shù)據(jù)

可以定義一個(gè)阻塞隊(duì)列，如BlockingQueue，在主線程中向隊(duì)列中放入數(shù)據(jù)，子線程從隊(duì)列中獲取數(shù)據(jù)。

以下是一個(gè)示例代碼：

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

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

        // 在主線程中放入數(shù)據(jù)
        blockingQueue.put("主線程的值");

        // 創(chuàng)建子線程
        Thread childThread = new Thread(() -> {
            try {
                // 在子線程中獲取數(shù)據(jù)
                String value = blockingQueue.take();
                System.out.println("子線程獲取的值：" + value);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });
        childThread.start();
    }
}

在這個(gè)例子中，我們使用LinkedBlockingQueue作為內(nèi)存隊(duì)列，在主線程中向隊(duì)列中放入數(shù)據(jù)，子線程從隊(duì)列中獲取數(shù)據(jù)。