快捷導(dǎo)航

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

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

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

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

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

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

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

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

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

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

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

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

可以使用 Java 中的并發(fā)集合，如ConcurrentHashMap來(lái)實(shí)現(xiàn)父子線(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<>();

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

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

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

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

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

可以定義一個(gè)阻塞隊(duì)列，如BlockingQueue，在主線(xiàn)程中向隊(duì)列中放入數(shù)據(jù)，子線(xiàn)程從隊(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<>();

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

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

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