Perl Promises模块无法并行运行问题求助

你的代码没法实现并行的核心原因在于**process函数里的逻辑是完全同步阻塞的**。当你调用process(10)时，它会立刻跑完整个for循环，才返回Promise；接着才会执行process(20)，以此类推——根本没有真正的异步并行执行的机会。

Promises本身只是异步操作的"容器"，如果里面没有异步任务，它和同步代码没区别。要实现并行，你需要把process里的工作改成非阻塞的异步操作，结合AnyEvent的事件循环来调度这些任务。

修改后的代码示例 #

use AnyEvent;
use Promises qw[ collect deferred ];
use Data::Dumper;

sub process {
    my ($data) = @_;
    my $d = deferred;
    
    # 用AnyEvent定时器模拟异步任务（实际场景可替换为AnyEvent::HTTP请求等异步操作）
    my $timer = AnyEvent->timer(
        after => 0,  # 立即加入事件循环队列
        cb    => sub {
            for (1..5) {
                print "\n$data " . $_ * $data;
            }
            $d->resolve($data);
        }
    );
    
    # 持有定时器引用，避免被垃圾回收提前销毁
    $d->promise->then(sub { undef $timer });
    
    return $d->promise;
}

# 创建条件变量，用于阻塞主线程等待所有异步任务完成
my $cv = AnyEvent->condvar;

collect(
    process(10),
    process(20),
    process(30),
)->then(
    sub {
        my @results = @_;
        print "\n\nAll tasks completed! Results: " . Dumper(\@results);
        $cv->send;
    },
    sub {
        my $error = shift;
        print "\nError occurred: $error";
        $cv->send;
    }
);

# 启动事件循环，等待所有任务结束
$cv->recv;

关键改动说明 #

• 引入AnyEvent定时器：把原本同步的循环放到定时器回调中，这样代码会被加入事件循环队列，而非立即阻塞执行。多个process调用的定时器会被事件循环同时调度，真正实现并行效果。
• 使用条件变量（condvar）：AnyEvent需要一个条件变量来阻塞主线程，否则程序会直接退出，来不及执行异步回调逻辑。
• 保留定时器引用：防止定时器被Perl的垃圾回收机制提前销毁，确保回调函数能正常执行。

实际场景扩展 #

如果你的真实需求是并行处理HTTP请求（你引入了AnyEvent::HTTP），可以把定时器替换为异步HTTP请求逻辑，示例如下：

use AnyEvent::HTTP;
use JSON::XS qw[ decode_json ];
use Promises qw[ collect deferred ];

sub fetch_data {
    my ($url) = @_;
    my $d = deferred;
    
    http_get $url, sub {
        my ($body, $headers) = @_;
        if ($headers->{Status} =~ /^2/) {
            $d->resolve(decode_json($body));
        } else {
            $d->reject("HTTP Error: $headers->{Status} $headers->{Reason}");
        }
    };
    
    return $d->promise;
}

# 并行发起多个HTTP请求
my $cv = AnyEvent->condvar;
collect(
    fetch_data("https://api.example.com/data/1"),
    fetch_data("https://api.example.com/data/2"),
    fetch_data("https://api.example.com/data/3"),
)->then(sub {
    my @responses = @_;
    # 处理返回的JSON数据
    print "Fetched all data successfully!\n";
})->catch(sub {
    my $error = shift;
    print "Request failed: $error\n";
})->finally(sub {
    $cv->send;
});

$cv->recv;

这样就能真正实现HTTP请求的并行处理了。

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