multithreading - Check number of alive threads -


i implementing boss-worker crew thread model in perl. due exceptions, worker thread exit abnormally.

once worker threads die(abnormal exit), jobs stucked, there no thread process workers_fn , boss thread keep enquing jobs.

thread 2 terminated abnormally: illegal division 0 @ threading.pl line 20. thread 3 terminated abnormally: illegal division 0 @ threading.pl line 20. thread 4 terminated abnormally: illegal division 0 @ threading.pl line 20. thread 5 terminated abnormally: illegal division 0 @ threading.pl line 20. thread 6 terminated abnormally: illegal division 0 @ threading.pl line 20. thread 7 terminated abnormally: illegal division 0 @ threading.pl line 20. thread 8 terminated abnormally: illegal division 0 @ threading.pl line 20. thread 9 terminated abnormally: illegal division 0 @ threading.pl line 20. thread 10 terminated abnormally: illegal division 0 @ threading.pl line 20. thread 11 terminated abnormally: illegal division 0 @ threading.pl line 20.

at point of time, how can detect accurately, number of alive workers thread?

#!/usr/bin/perl use strict; use warnings; use carp; use diagnostics;  use threads; use thread::queue;  use data::dumper;  use constant {     workers_cnt => 10,     };  $queue= new thread::queue(); sub workers_fn{      #producing exceptions deliberately test case      $random_number = int(time);     if($random_number %2==0 || $random_number %3==0 || $random_number %5==0){         print "crashed:".5/($random_number %2);         print "\n";     }      while (my $query = $queue->dequeue) {         print "deq(".threads->tid.") :$query\n";     }  } sub master_fn(){     $totalentry=10000;     while($totalentry -- > 0){         $query = localtime;         $queue->enqueue($query);         print "enq(".threads->tid.") :$query\n";         sleep(1);          #check worker threads alive         {           #how check number of alive threads?????????????         }      } }  $master_th=threads->create(\&master_fn);  @worker_th=map threads->create(\&workers_fn), 1..workers_cnt; $master_th->join; $queue->enqueue(undef) 1..workers_cnt;  (@worker_th){     $_->join; 

my $running = threads->list(threads::running); 
$ perl -mthreads -mthreads::shared -mtime::hires=sleep -e'    $hold : shared;    {       lock($hold);        async { sleep 1; die "ack" };       async { lock($hold) };        while (1) {          $running = threads->list(threads::running);          $running;          last if $running < 2;          sleep 0.1;       }    }     $_->join threads->list; ' 2 2 2 2 2 2 2 2 2 2 thread 1 terminated abnormally: ack @ -e line 6. 1

Comments

Post a Comment

Popular posts from this blog

javascript - RequestAnimationFrame not working when exiting fullscreen switching space on Safari -

request animation frame stops working when exiting fullscreen clicking on original space's safari window. fine if fullscreen mode canceled escape key or calling cancelfullscreen(). steps reproduce: open https://dl.dropboxusercontent.com/u/769042/prezi/safari-fullscreen.html click "draw raf", kittie appears click "fullscreen", go fullscreen click "draw raf", kittie appears go space original safari was, showing "click exit fullscreen mode", click anywhere, out fullscreen click "draw raf", nothing happens what handling click calling: window.requestanimationframe(draw); which draws on canvas context: function draw() { ctx.drawimage(img, math.random()*500|0, math.random()*400|0, 100, 100); } i checked .hidden , .visibilitystate, updated correctly. tested on osx 10.9.3, safari 7.0.4 (9537.76.4). has workaround/solution other switching old settimeout? this sounds webkit bug 88940 : using reque...
Read more

jsf - How to ajax update an item in the footer of a PrimeFaces dataTable? -

this visual of table have: +---------+------------+-------------------+ | header1 | header2 | header3 | +---------+------------+-------------------+ | row | input | calc'ed output | | row b | input b | calc'ed output b | | etc.. | etc.. | etc.. | +---------+------------+-------------------+ | total: total calc'ed output | +------------------------------------------+ and stripped-down code: <p:datatable id="mytable" value="#{mybean.somelist}" var="currentitem"> <p:column headertext="header1"> <h:outputtext value="#{currentitem.name}" /> </p:column> <p:column headertext="header2"> <pe:inputnumber value="#{currentitem.inputval}"> <p:ajax event="change" listener="#{mybean.changelistener}" update="outputval outputtotal...
Read more

jquery - Keeping Kendo Datepicker in min/max range -

when user types type in date outside of range, we're trying ensure date gets changed closest min/max. text displayed in date picker not change though thought script changing value() @(html.kendo() .datepickerfor(x => x.dob) .max(new datetime(datetime.now.addyears(-18).year, datetime.now.addyears(-18).month, datetime.now.addyears(-18).day)) .min(new datetime(datetime.now.addyears(-70).year, datetime.now.addyears(-70).month, datetime.now.addyears(-70).day)) .events(e=>e.change("ondobchange")) .htmlattributes(new { required = "required", ng_model = "model.dob" })) <p ng-show="validatestate.submitted && frmmain.dob.$invalid" class="help-block">please select</p> <script> function ondobchange(e) { var d...
Read more