有没有一种简单的方法可以让 SQL 语句超时,这样它就会失败而不是等待(例如,传递一个空的结果集或错误消息或其他任何东西),这样我就可以让一个作业的资源预留失败并给另一个机会?我正在寻找迄今为止我忽略的一些 DBI 选项;向自己发送 SIGALRM 以自杀并不是我的想法(尽管如果必须的话,我可能不得不求助于那个)。
被剪断的代码是伪代码并被缩短到了极点,但我希望你能明白其中的意思。
my $sql = "SELECT one, two, three FROM sometable WHERE this = ? AND that = ?";
my $sth = $self->make_handle( $sql );
eval {
foreach my $this ( sort keys %needed_ressources ) {
# vvv This is where the idle time is spent vvv
$sth->execute( $this, $that ) or die( "DB connection gone?!" );
# ^^^ This is where the idle time is spent ^^^
my ( $one, $two, $three ) = $sth->fetchrow_array();
unless( $one ) { # undefined record set == not found
$self->{DB_HANDLE}->rollback();
die( "$this not defined for $that!" );
}
}
# If we haven't died so far, we can move on
foreach... #similar loop here doing the actual update statement
$self->{DB_HANDLE}->commit();
};
return( 1 ) unless $@;
return( undef );
以下是有兴趣的血腥细节:
在进行大规模并行数字运算的应用程序中,有一个使用 oracle 表实现的资源锁定机制。每个作业都需要锁定多个读取资源和/或写入多个资源,并且只有在成功获取所有锁后才能启动。与其耐心等待资源被释放,不如让作业失败并稍后由它们的主人重新运行(这可以保持打开事务的数量较低,同时通过在实际紧缩时提供更多作业来提高性能)。
当然,在实际更新表之前,每行都使用“SELECT ... FOR UPDATE”语句保留,因此 Oracle 使用行级锁定,并发事务可以在表上发生。为了进一步减少可能的竞争条件和死锁,所有作业首先选择它们的资源行,然后在执行更新之前使用相同的顺序对它们进行行锁定。
截至目前的实施,这在大多数情况下都可以正常工作。但是,因为在 Oracle 实际授予行锁之前“选择更新”会阻塞,因此可能仍然会发生作业空闲等待其资源的情况,而我正在寻找这些以更好地利用可用的 CPU 能力。等待一两秒钟是可以的,但不是十秒钟或更长时间只是为了锁定。稍后解锁,当然需要等待,因此将整个数据库连接设置为只接受即时结果是行不通的。
我总是感谢RTFM的答案,只要它们指向M中我应该TF有R的位置;-))
非常感谢,
奥尔凡