use Cache::Memcached::LibMemcached; my $memd = Cache::Memcached::LibMemcached->new({ serves => [ "10.0.0.15:11211", "10.0.0.15:11212", "/var/sock/memcached" ], compress_threshold => 10_000 }); $memd->set("my_key", "Some value"); $memd->set("object_key", { 'complex' => [ "object", 2, 4 ]}); $val = $memd->get("my_key"); $val = $memd->get("object_key"); if ($val) { print $val->{complex}->[2] }

# 追加前 shell > 堂本光一 堂本 名詞,固有名詞,人名,姓,*,*,堂本,ドウモト,ドーモト 光一 名詞,固有名詞,人名,名,*,*,光一,コウイチ,コーイチ # 追加後 shell > mecab 堂本光一 堂本光一 名詞,固有名詞,人名,*,*,*,堂本光一,どうもとこういち,*

use Queue::Q4M; my $q = Queue::Q4M->connect( connect_info => [ 'dbi:mysql:dbname=mydb', $username, $password ], table => 'q4m' ); for (1..10) { $q->insert(\%fieldvals); } while ($q->next) { my ($col1, $col2, $col3) = $q->fetch(\@fields); print "col1 = $col1, col2 = $col2, col3 = $col3\n"; } while ($q->next) { my $cols = $q->fetch_arrayref(\@fields); print "col1 = $cols->[0], col2 = $cols->[1], col3 = $cols->[2]\n"; } while ($q->next) { my $cols = $q->fetch_hashref(\@fields); print "col1 = $cols->{col1}, col2 = $cols->{col2}, col3 = $cols->{col3}\n"; } $q->disconnect;

use strict; use warnings; use DBI; use Time::HiRes qw(time); my $TEST_ROWS = $ENV{TEST_ROWS} || 1024; my $dbh = DBI->connect( $ENV{DBI} || 'dbi:mysql:database=test;host=localhost', $ENV{DBI_USER} || 'root', $ENV{DBI_PASSWORD} || '', ) or die 'connection failed:'; $dbh->do('drop table if exists q4m_t'); $dbh->do('create table q4m_t (v int not null) engine=queue'); my $insert_time = 0; my $select_time = 0; my $insert = $dbh->prepare("insert into q4m_t (v) values (?)"); for (my $i = 0; $i < $TEST_ROWS; $i++) { my $start = time(); $insert->execute($i); $insert_time += time() - $start; } my $sth = $dbh->prepare("select queue_wait('test.q4m_t')"); for(0..$TEST_ROWS - 1) { my $start = time(); if ($sth->execute()) { my $h = $sth->fetchrow_hashref(); } else { last; } $select_time += time() - $start; } $dbh->do('select queue_end()'); print STDERR "$TEST_ROWS items used\n"; print STDERR " avg insert time: ", $insert_time / $TEST_ROWS, "\n"; print STDERR " avg select time: ", $select_time / $TEST_ROWS, "\n";

daisuke@beefcake q4m$ env TEST_ROWS=128 perl queue.pl 128 items used avg insert time: 0.0969786122441292 avg select time: 0.0974297747015953 daisuke@beefcake q4m$ env TEST_ROWS=256 perl queue.pl 256 items used avg insert time: 0.107754170894623 avg select time: 0.115405934862792 daisuke@beefcake q4m$ env TEST_ROWS=512 perl queue.pl 512 items used avg insert time: 0.0976005531847477 avg select time: 0.0964000821113586

use GunghoX::GSL; config( engine => { module => 'POE' } ); process { # Simple request. This is equivalent of saying # request { # url => 'http://search.cpan.org' # } # or # request_build { # my $req = Gungho::Request->new(GET => 'http://search.cpan.org'); # return $req; # }; request 'http://search.cpan.org'; # Handle the previous response response { my $response = shift; # do something with $response } }; process { request { name => 'BEGIN', url => 'http://search.cpan.org', }; response_for 'BEGIN', { my $response = shift; my @links = ...; # follow links foreach my $link (@links) { request { name => 'follow', url => $link } } }; response_for 'follow' { my $response = shift; # do something with $response } };

取り急ぎ"process"に代わる名前が欲しいところだな。