Perl,fork,信号量,进程
我需要创建一个程序,从列表中以随机顺序同时运行3个进程,并逐个锁定这些进程,以避免重复.
例如,您有3个程序的列表: @array = ( 1,2,3); > perl script.pl最初运行2; 到目前为止,这是我的代码: #!/usr/bin/perl -w use IPC::SysV qw(IPC_PRIVATE S_IRUSR S_IWUSR IPC_CREAT); use IPC::Semaphore; use Carp (); print "Program startedn"; 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; 问题: >需要锁定文件; (我不知道如何使用信号量.一些锁定文件的尝试失败,因此排除了该代码.) 解决方法
你的随机性要求非常奇怪,但如果我理解你的要求,你就不需要任何锁定来做你想做的事情. (所以1)你的问题已经消失了)
首先调整程序数组,然后启动该混洗数组的每个命令(这将处理你的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 $pidn"; push @pids,$pid; } } # Wait for them map { waitpid($_,0); print "$_ done!n"; } (@pids); 不确定洗牌是最好的,但它确实有效.它背后的想法只是从初始(已排序)列表中随机选择一个元素,将其从那里删除并将其添加到混洗的元素.重复,直到初始列表为空. 如果你试图在系统范围内锁定程序(即系统中没有其他进程能够启动它们),那么我很抱歉,除非程序保护自己免于并发执行,否则这是不可能的. 如果你的问题是关于信号量,那么我很抱歉我错过了你的观点. IPC documentation有示例代码.我并不认为有必要为你想要做的事情去那种复杂性. 以下是使用 在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; 如果清理没有正确完成(即代码启动时信号量已经存在),这段代码缺乏正确的错误检查,会奇怪地工作(即根本不好).但它应该让你开始. (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |