1

AnyEvent を使用して、X 分ごとにイベントをトリガーしています。一部のプロセスは長く、データベースに記録する結果は、記録するのに長い場合があります (3 秒以上の場合もあります)。データベースに同時にアクセスする関数が 1 つだけであることを確認したいと思います。そこで、threads::shared モジュールの lock を使用します。これが私のコードです:

main.pl:

my $var :shared;
$var = 0;

my $w1 = AnyEvent->timer(after => 0, interval => 120, cb => sub {
my @targeted_users = TargetUsers::get_targeted_account_from_followers($dbh,$account,'myrhline');
TargetUsers::save_users_to_follow($dbh,'RH',$var,@targeted_users);
});

my $w2 = AnyEvent->timer(after => 0, interval => 120, cb => sub {
my @targeted_users2 = TargetUsers::get_targeted_account_from_followers($dbh,$account2,'actuel_rh');
TargetUsers::save_users_to_follow($dbh,'RH',$var,@targeted_users2);
});

AnyEvent::Loop::run;

対象ユーザー:

sub save_users_to_follow{
my ($dbh,$topic,$var,@targeted_users) = @_;

lock($var); #I call lock($var) to lock the access to the database.

my @array1 = ();

$dbh->{AutoCommit} = 0;

my $sth2 = $dbh->prepare(
"UPDATE People_TO_FOLLOW
         SET   Pertinence       = Pertinence + 1
         WHERE Id_user = ?");

my $tuples_update = $sth2->execute_array(
{ ArrayTupleStatus => \my @tuple_status_update },
\@targeted_users,
);

if ($tuples_update) {
print "Successfully updated $tuples_update records\n";
}
else {
for my $tuple_1 (0..$#targeted_users) {
    my $status_1 = $tuple_status_update[$tuple_1];
    $status_1 = [0, "Skipped"] unless defined $status_1;
    next unless ref $status_1;
    printf "Failed to update (%s): %s\n",
        $targeted_users[$tuple_1], $status_1->[1];
}
}
$sth2->finish();

my $sth = $dbh ->prepare(
"INSERT OR IGNORE INTO People_TO_FOLLOW(Id_user,Topic,Already_followed,Pertinence) VALUES (?,'$topic',0,1)");

my $tuples_insert = $sth->execute_array(
{ ArrayTupleStatus => \my @tuple_status_insert },
\@targeted_users,
);

if ($tuples_insert) {
print "Successfully inserted $tuples_insert records\n";
}
else {
for my $tuple_2 (0..$#targeted_users) {
    my $status_2 = $tuple_status_insert[$tuple_2];
    $status_2 = [0, "Skipped"] unless defined $status_2;
    next unless ref $status_2;
    printf "Failed to insert (%s): %s\n",
    $targeted_users[$tuple_2], $status_2->[1];
}
}
$sth->finish();
$dbh->commit;
$dbh->{AutoCommit} = 1;    
}

しかし、私はこのエラーを受け取ります:「ロックは共有値でのみ使用できます」

アイデアはありますか？ありがとう

4

1 に答える 1

4

という名前の変数が 2 つあり、 $var1 つは にmain.pl、もう 1 つは にありsave_users_to_followます。前者は共有変数ですが、後者をロックしようとしています。

var を main から TargetUsers に移動するか、lock var への参照を に渡しsave_users_to_followます。

于 2014-05-13T13:01:27.310 に答える