基本上我想：
>将大量数据从网络读入阵列到内存中.
>异步写入此数组数据,在它到达磁盘之前通过bzip2运行它.
重复..
这可能吗？如果这是可能的,我知道我将不得不以某种方式读取下一个数据传递到不同的数组,因为AIO文档说在异步写入完成之前不得更改此数组.我想将所有写入磁盘的顺序放在后面,因为bzip2传递比网络读取需要更长的时间.
这可行吗？下面是我认为需要的一个简单示例,但这只是将文件读入数组@a进行测试.
use warnings;
use strict;
use EV;
use IO::AIO;
use Compress::Bzip2;
use FileHandle;
use Fcntl;
my @a;
print "loading to array...\n";
while(<>) {
$a[$. - 1] = $_;
}
print "array loaded...\n";
my $aio_w = EV::io IO::AIO::poll_fileno,EV::WRITE,\&IO::AIO::poll_cb;
aio_open "./out",O_WRONLY || O_NONBLOCK,sub {
my $fh = shift or die "error while opening: $!\n";
aio_write $fh,undef,$a,-1,sub {
$_[0] > 0 or die "error: $!\n";
EV::unloop;
};
};
EV::loop EV::LOOP_NONBLOCK;
解决方法
Asynchronously write this array data
仅供参考,write()s几乎总是异步的.除非您填写操作系统写入缓存.
与启动普通管道相比,使用AIO所获得的收益很少,例如未经测试：
my $socket; # INET something
my $out = new IO::Handle;
open($out,"|bzip2 > ./out") || die;
while (1) {
my $buf;
$socket->recv($buf,64*1024,0);
last unless defined $buf and length $buf;
print $out $buf;
}
close($out);
在大多数操作系统下,很难生成足以填满写缓存的大量信息.至少在管道中使用bzip2：HDD的吞吐量比压缩性能(在每秒兆字节范围内)高得多(> 50MB / s).
如果你想在后台运行它或者并行运行多个流,不必担心fork()并使用child()从子节点向主程序发出信号,指示操作是如何进行的.
据我所知,AIO最有用(也可能是唯一有用)的方面是异步读取.这无法以任何其他方式实现.使用AIO只进行异步写入很有意义.