view release on metacpan or  search on metacpan

benchmarking/bench-fit-parallel.pl  view on Meta::CPAN

#!/usr/bin/perl
# benchmarking/bench-fit-parallel.pl
#
# Measures fit() throughput across a sweep of parallel_fit worker
# counts.  The training data is the same for every run; only the
# `parallel_fit` constructor option changes.
#
# parallel_fit forks workers and divvies up n_trees across them, with
# each worker fitting its share in a child process (via the C tree
# builder when Inline::C is available, same as a non-parallel fit) and
# returning the trees to the parent via Storable on a pipe.  Speedup is
# bounded by:
#   * core count
#   * Storable freeze/thaw + pipe IPC overhead per worker
#   * fork() cost (small but non-zero)
#
# With the C builder, a single-process fit is often fast enough that
# this fixed per-worker overhead costs more than splitting the work
# saves -- watch for parallel_fit making things *slower* on small/
# medium datasets in the sweep below.
#
# Run with:
#   perl -Ilib benchmarking/bench-fit-parallel.pl

use strict;
use warnings;
use lib '../lib';
use FindBin;
use lib "$FindBin::Bin";
use BenchAccel qw(wall_time_median);
use Config;
use Algorithm::Classifier::IsolationForest;

use constant PI => 3.14159265358979;

sub gaussian {
	my ( $mu, $sigma ) = @_;
	return $mu + $sigma * sqrt( -2 * log( rand() || 1e-12 ) ) * cos( 2 * PI * rand() );
}

# -----------------------------------------------------------------------
# Parameters
# -----------------------------------------------------------------------
my $N_TRAIN     = 5_000;
my $N_FEATURES  = 8;
my $N_TREES     = 200;
my $SAMPLE_SIZE = 256;
my $REPS        = 5;
my @workers     = ( 1, 2, 4, 8 );

# -----------------------------------------------------------------------
# Generate training data once (outside any timing).
# -----------------------------------------------------------------------
srand(42);
my @train = map {
	[ map { gaussian( 0, 1 ) } 1 .. $N_FEATURES ]
} 1 .. $N_TRAIN;
push @train, [ map { 6 + rand() } 1 .. $N_FEATURES ] for 1 .. 50;

# -----------------------------------------------------------------------
# Detect environment
# -----------------------------------------------------------------------
my $can_fork   = ( $Config{d_fork} || '' ) eq 'define';
my $has_c      = $Algorithm::Classifier::IsolationForest::HAS_C      ? 'yes' : 'no';
my $has_openmp = $Algorithm::Classifier::IsolationForest::HAS_OPENMP ? 'yes' : 'no';

print "=" x 67, "\n";
print " fit() parallelism sweep (parallel_fit constructor option)\n";
print "=" x 67, "\n";
printf " Training: %d samples, %d features, %d trees, sample_size=%d\n", $N_TRAIN, $N_FEATURES, $N_TREES, $SAMPLE_SIZE;
printf " Median of %d fits per worker count\n",        $REPS;
printf " Inline::C: %s   OpenMP: %s   fork(): %s\n\n", $has_c, $has_openmp, $can_fork ? 'yes' : 'no';

unless ($can_fork) {
	print " (fork() not available on this platform; parallel_fit falls back to serial)\n";
}