例如,您有3个程序的列表：
@array = ( 1,2,3);
> perl script.pl最初运行2;
>通过随机尝试再次运行2并收到错误(因为2现在已被信号量锁定).
>运行1.
>运行3.
> script.pl等待所有1,3结束工作,然后退出自己.
到目前为止,这是我的代码：
#!/usr/bin/perl -w
use IPC::SysV qw(IPC_PRIVATE S_IRUSR S_IWUSR IPC_CREAT);
use IPC::Semaphore;
use Carp ();
print "Program started\n";
sub sem {
#semaphore lock code here
}
sub chooseProgram{
#initialise;
my $program1 = "./program1.pl";
my $program2 = "./program2.pl";
my $program3 = "./program3.pl";
my $ls = "ls";
my @programs = ( $ls,$program1,$program2,$program3 );
my $random = $programs[int rand($#programs+1)];
print $random."\n";
return $random;
}
#parent should fork child;
#child should run random processes;
#avoid process clones with semaphore;
sub main{
my $pid = fork();
if ($pid){
#parent here
}
elsif (defined($pid)){
#child here
print "$$Child started:\n";
#simple cycle to launch and lock programs
for (my $i = 0; $i<10; $i++){
# semLock(system(chooseProgram()); #run in new terminal window
# so launched programs are locked and cannot be launched again
}
}
else {
die("Cannot fork: $!\n");
}
waitpid($pid,0);
my $status = $?;
#print $status."\n";
}
main();
exit 0;
问题：
>需要锁定文件; (我不知道如何使用信号量.一些锁定文件的尝试失败,因此排除了该代码.)
>孩子等到第一个节目在第二次开始前结束.如何与一个孩子同时开始三个项目？ (是否可以或应该为一个程序创建一个孩子？).
>程序是非gui,应该在终端运行.如何在新的终端窗口(选项卡)中运行程序？
>没有正确检查是否所有@programs程序都已启动. – 不太重要.
解决方法
首先调整程序数组,然后启动该混洗数组的每个命令(这将处理你的4)).然后只有waitpid你开始一切(处理你的2)).
下面的代码就是这样,在新终端中启动各种睡眠实例(我使用urxvt,根据你想要产生的终端进行调整 – 这将处理你的3)).
#! /usr/bin/perl -w
use strict;
use warnings;
my @progs = ("urxvt -e sleep 5","urxvt -e sleep 2","urxvt -e sleep 1");
my @sgrop;
my @pids;
# Shuffle the programs
while (my $cnt = scalar(@progs)) {
push @sgrop,splice @progs,int(rand($cnt)),1;
}
# Start the progs
foreach my $prog (@sgrop) {
my $pid = fork();
if (!$pid) {
exec($prog);
# exec does not return
} else {
print "Started '$prog' with pid $pid\n";
push @pids,$pid;
}
}
# Wait for them
map {
waitpid($_,0);
print "$_ done!\n";
} (@pids);
不确定洗牌是最好的,但它确实有效.它背后的想法只是从初始(已排序)列表中随机选择一个元素,将其从那里删除并将其添加到混洗的元素.重复,直到初始列表为空.
如果你试图在系统范围内锁定程序(即系统中没有其他进程能够启动它们),那么我很抱歉,除非程序保护自己免于并发执行,否则这是不可能的.
如果你的问题是关于信号量,那么我很抱歉我错过了你的观点. IPC documentation有示例代码.我并不认为有必要为你想要做的事情去那种复杂性.
以下是使用IPC::Semaphore模块进行操作的方法.
在main的开头,创建一个信号量集,其中包含所需数量的信号量：
use IPC::SysV qw(S_IRUSR S_IWUSR IPC_CREAT IPC_NOWAIT);
use IPC::Semaphore;
my $numprocs = scalar(@progs);
my $sem = IPC::Semaphore->new(1234,# this random number is the semaphore key. Use something else
$numprocs,# number of semaphores you want under that key
S_IRUSR | S_IWUSR | IPC_CREAT);
检查错误,然后将所有信号量初始化为1.
$sem->setall( (1) x $numprocs) || die "can't set sems $!";
在启动进程的代码中,在开始之前(虽然在fork之后),尝试获取信号量：
if ($sem->op($proc_number,-1,IPC_NOWAIT)) {
# here,you got the semaphore - so nothing else is running this program
# run the code
# and once the code is done:
$sem->op($proc_number,1,0); # release the semaphore
exit(0);
} else {
# someone else is running this program already
exit(1); # or something
}
在上面,$proc_number对于每个程序必须是唯一的(例如,它可能是程序数组中的索引).不要使用exec来启动程序.例如,使用系统.
请注意,在这种情况下,您必须处理子进程的退出代码.如果退出代码为零,则可以将该程序标记为已运行.如果没有,您需要重试. (这会变得混乱,你需要跟踪哪个程序运行.我建议使用程序号($proc_number)的哈希值来存储它是否已经完成,以及当前pid运行(或试图运行)该代码.您可以使用该哈希来确定仍需要执行的程序.)
最后一切都结束了,你等了所有的孩子,你应该自己清理：
$sem->remove;
如果清理没有正确完成(即代码启动时信号量已经存在),这段代码缺乏正确的错误检查,会奇怪地工作(即根本不好).但它应该让你开始.