Prty::Parallel - Parallele Verarbeitung
Prty::Object
Minimales Veranschaulichungsbeispiel: Lasse 50 Prozesse für jeweils eine Sekunde schlafen. Die Ausführungsdauer beträgt ungefähr 50/Anzahl CPUs Sekunden, da immer Anzahl CPUs Prozesse parallel ausgeführt werden.
Prty::Parallel->runArray([1..50],sub { my ($elem,$i) = @_; sleep 1; return; });
Bei großen Datenmengen oder wenn die Gesamtmenge vorab nicht bekannt ist, bietet sich die Methode $class->"runFetch"() an. Hier ein Beispiel mit einer unbekannt großen Datenbank-Selektion:
my $cur = $db->select(" <SELECT Statement> ", -cursor => 1, ); Prty::Parallel->runFetch(sub { my $i = shift; return $cur->fetch; }, sub { my ($row,$i) = @_; <$row verarbeiten> return; }, );
$class->runArray(\@elements,$sub,@opt);
Die Elemente, auf denen die Berechnung einzeln durchgeführt wird.
Die Subroutine, die für jedes Element in @elements ausgeführt wird.
Die maximale Anzahl parallel laufender Prozesse.
Zeige Fortschrittsanzeige an.
nichts
$class->runFetch($fetchSub,$execSub,@opt);
Verarbeite die Elemente, die von Subroutine $fetchSub geliefert werden, mit der Subroutine $execSub mit parallel laufenden Prozessen. Per Default wird für die Anzahl der parallelen Prozesse die Anzahl der CPUs des ausführenden Rechners gewählt. Mit der Option -maxProcesses kann eine abweichende Anzahl gewählt werden.
Tip: Die Anzahl der vorhandenen CPUs liefert die Methode
$n = Prty::System->numberOfCpus;
Subroutine, die das nächste gefetchte Element liefert:
$e = $fetchSub->($i); # $i-ter Fetch-Aufruf
Subroutine, die für jedes gefetchte Element ausgeführt wird.
Gesamtanzahl der Fetches. 0 bedeutet, die Gesamtanzahl der Fetches ist (vorab) nicht bekannt.
1.112
Frank Seitz, http://fseitz.de/
Copyright (C) 2017 Frank Seitz
This code is free software; you can redistribute it and/or modify it under the same terms as Perl itself.
To install Prty, copy and paste the appropriate command in to your terminal.
cpanm
cpanm Prty
CPAN shell
perl -MCPAN -e shell install Prty
For more information on module installation, please visit the detailed CPAN module installation guide.