-
Notifications
You must be signed in to change notification settings - Fork 0
/
Basic.pm
47 lines (31 loc) · 810 Bytes
/
Basic.pm
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
package Basic;
use strict;
use warnings;
use Data::Dumper;
use Scalar::Util qw(blessed);
use ProcessorRange;
sub new {
my ($class) = @_;
my $self = {};
bless $self, $class;
return $self;
}
sub reduce {
my ($self, $job, $left_processors) = @_;
my $target_number = $job->requested_cpus();
my @remaining_ranges;
$left_processors->ranges_loop(
sub {
my ($start, $end) = @_;
my $taking = $target_number;
my $available_processors = $end + 1 - $start;
$taking = $available_processors if ($available_processors < $target_number);
push @remaining_ranges, [$start, $start + $taking - 1];
$target_number -= $taking;
return ($target_number != 0);
}
);
$left_processors->affect_ranges(ProcessorRange::sort_and_fuse_contiguous_ranges(\@remaining_ranges));
return;
}
1;