Ryan
/
AdventOfCode
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

wip

This commit is contained in:
Ryan 2025-12-07 22:44:24 -05:00
parent d0ff801e7d
commit ff1745df3a
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
day07/run.pl
View File

@ -49,13 +49,13 @@ for(my $y=0; $y<@lines; $y++) {
} }
my $ends = 0; my $ends = 0;
my $numworkers = 16; my $numworkers = $ARGV[0] || 16;
my $queue = Thread::Queue->new(); my $queue = Thread::Queue->new();
my @threads; my @threads;
$queue->enqueue($startpos); $queue->enqueue($startpos);
for(my $i=0; $i<$numworkers; $i++) { for(my $i=0; $i<$numworkers; $i++) {
push @threads, threads->create(\&process); push @threads, threads->create(\&process, $i);
} }
foreach my $thread (@threads) { foreach my $thread (@threads) {
@ -66,8 +66,12 @@ foreach my $thread (@threads) {
print "$ends total ends\n"; print "$ends total ends\n";
sub process { sub process {
my $threadid=shift(@_);
my $ends = 0; my $ends = 0;
while(my $pos=$queue->dequeue_timed(5)) { while(my $pos=$queue->dequeue_timed(5)) {
if($threadid == 0) {
print $queue->pending() . " pending\n";
}
my($x,$y)=@$pos; my($x,$y)=@$pos;
for(;;) { for(;;) {
@ -77,8 +81,9 @@ sub process {
last; last;
} elsif($rows[$x][$y] eq '^') { } elsif($rows[$x][$y] eq '^') {
$queue->enqueue([$x-1, $y]); $queue->enqueue([$x-1, $y]);
$queue->enqueue([$x+1, $y]); $x++;
last; #$queue->enqueue([$x+1, $y]);
#last;
} }
} }
} }