X-Git-Url: https://git.ktnx.net/?a=blobdiff_plain;f=lib%2FApp%2FMPD%2FFeeder%2FWorkQueue.pm;fp=lib%2FApp%2FMPD%2FFeeder%2FWorkQueue.pm;h=0000000000000000000000000000000000000000;hb=56f67022f26164779f53113b23da804304ad4cdc;hp=aa21fb027c5fe0204e9ce94ce0bf2ebe62d67189;hpb=27e88cd9f6dd4015336561709a8b114249e26a58;p=mpd-feeder.git diff --git a/lib/App/MPD/Feeder/WorkQueue.pm b/lib/App/MPD/Feeder/WorkQueue.pm deleted file mode 100644 index aa21fb0..0000000 --- a/lib/App/MPD/Feeder/WorkQueue.pm +++ /dev/null @@ -1,48 +0,0 @@ -use v5.28; -use utf8; -use Object::Pad; -class App::MPD::Feeder::WorkQueue; - -use Log::Any qw($log); - -has @queue; -has %present; - -method add($key) { - if ( exists $present{$key} ) { - $log->trace("job '$key' already queued"); - } - else { - $present{$key} = undef; - push @queue, $key; - - $log->trace("job '$key' queued"); - } -} - -method next { - my $item = shift @queue; - - if ( defined($item) ) { - $log->trace("next job: '$item'"); - delete $present{$item}; - } - else { - $log->trace("job queue is empty"); - } - - return $item; -} - -method clear { - @queue = (); - %present = (); - $log->trace('work queue cleared'); -} - -method has_jobs { - $log->trace( "Queue jobs: " . scalar(@queue) ); - return scalar @queue; -} - -1;