Perl，fork，semaphores，process

如何解决Perl，fork，semaphores，process

| 我需要创建一个程序，该程序可以从列表中以随机顺序同时运行3个进程，并用信号灯一一锁定这些进程，以避免重复。例如，您有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的所有程序是否已启动。 - 不太重要。

解决方法

您的随机性要求很奇怪，但是如果我正确理解了您的要求，则您不需要任何锁定就可以执行您想要的操作。（所以您问题中的2英镑消失了）首先改组程序数组，然后启动改组后的数组的每个命令（这涉及到您的4)）。然后，在您开始一切操作之后，才剩下waitpid（处理您的2)）。下面的代码做到了这一点，在新终端中启动了各种sleep实例（我使用urxvt，根据您希望生成的终端进行调整-这将处理您的ѭ8deals）。

#! /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文档提供了示例代码。我真的不认为有必要针对这种复杂性进行尝试。为方便起见，这里是使用IPC::Semaphore模块的方法。在主程序的开头，创建一个信号量集，其中包含所需数量的信号量：

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
}

在上面，“ 14”对于每个程序都必须是唯一的（例如，它可以是程序数组中的索引）。不要使用ѭ15来启动程序。例如，使用system。请注意，在这种情况下，您将不得不处理子进程的退出代码。如果退出代码为零，则可以将该程序标记为已运行。如果不是，则需要重试。（这会变得很混乱，您需要跟踪是否运行了哪个程序。我建议使用程序号（$proc_number）作为一个哈希值，用于存储程序是否已完成，以及当前运行（或尝试运行）该代码的pid。您可以使用该哈希值来找出仍需要执行的程序。）最后，在完成所有工作并等待所有孩子之后，您应该自己清理一下：

$sem->remove;

此代码缺少适当的错误检查，如果清理未正确完成（即，在代码启动时信号量已经出现），它将无法正常工作（即完全无法正常工作）。但这应该可以帮助您入门。

Perl，fork，semaphores，process

如何解决Perl，fork，semaphores，process

解决方法

相关推荐