Perl多进程（fork）/多线程/同步问题：如何实现跨执行单元的哈希数据共享

Ah, I see the issue here—when you use fork(), the child process gets its own copy of the parent's entire memory space. That means the $milon hash in the child is a separate entity from the parent's version; any changes the child makes won't show up in the parent's hash. Let's go through a few solid solutions to get that cross-execution-unit data sharing working, depending on your needs:

方案1：使用共享内存（IPC::Shareable） #

这个模块让你可以在进程间共享变量，包括哈希。首先需要安装它：

cpan IPC::Shareable

修改后的代码示例：

use IPC::Shareable;
use Data::Dumper;

# 设置共享内存的密钥和选项
my $key = 'shared_hash_key';
my %options = (
    create    => 1,
    exclusive => 0,
    mode      => 0644,
    destroy   => 1, # 进程结束后自动清理共享内存
);

# 将哈希绑定到共享内存
tie my %milon, 'IPC::Shareable', $key, { %options };

my $pid = fork();
die "Fork failed: $!" if not defined $pid;

if (not $pid) {
    # 子进程修改共享哈希
    $milon{$pid} = $pid;
    exit;
}

# 父进程修改哈希
$milon{3} = 4;

# 等待子进程完成
my $finished = wait();

# 打印结果，现在会包含两个键值对
print( "debug10: TEST = ", Dumper(\%milon));

说明：通过tie把哈希绑定到共享内存后，父子进程操作的是同一块内存空间，修改会互相可见。适合需要频繁读写共享数据的场景。

方案2：使用多线程（threads + threads::shared） #

Perl的线程共享同一个地址空间，所以可以直接共享哈希，不需要额外的IPC机制。示例代码：

use threads;
use threads::shared;
use Data::Dumper;

# 声明哈希为共享变量
my %milon : shared;

# 创建子线程
my $thread = threads->create(sub {
    # 子线程修改共享哈希
    my $tid = threads->tid();
    $milon{$tid} = $tid;
});

# 父线程修改哈希
$milon{3} = 4;

# 等待子线程完成并回收资源
$thread->join();

# 打印结果，会包含两个键值对
print( "debug10: TEST = ", Dumper(\%milon));

说明：用: shared属性标记哈希为共享后，子线程的修改会直接反映到主线程的哈希中。注意Perl的线程有全局解释器锁（GIL），更适合IO密集型任务，CPU密集型场景可能不如多进程高效。

方案3：使用进程间通信（IPC）传递数据 #

如果不需要实时共享，只是在子进程结束后把数据传递给父进程，可以用管道或者消息队列。这里用管道的示例：

use Data::Dumper;
use Storable qw(freeze thaw);

# 创建双向管道
pipe(my $reader, my $writer) or die "Pipe failed: $!";

my $pid = fork();
die "Fork failed: $!" if not defined $pid;

if (not $pid) {
    close $reader; # 子进程关闭读端
    my %child_hash;
    $child_hash{$pid} = $pid;
    # 把哈希序列化后写入管道
    print $writer freeze(\%child_hash);
    close $writer;
    exit;
}

close $writer; # 父进程关闭写端
my %milon;
$milon{3} = 4;

# 读取子进程发送的数据并反序列化
my $child_data = do { local $/; <$reader> };
my $child_hash = thaw($child_data);
close $reader;

# 合并两个哈希
%milon = (%milon, %$child_hash);

my $finished = wait();

print( "debug10: TEST = ", Dumper(\%milon));

说明：子进程把自己的哈希序列化（用Storable的freeze）后通过管道发送给父进程，父进程反序列化后合并到自己的哈希中。这种方式耦合度低，适合简单的数据汇总场景。

内容的提问来源于stack exchange，提问作者urie