Beefy Boxes and Bandwidth Generously Provided by pair Networks
Perl: the Markov chain saw
 
PerlMonks  

Updating global variable in multi-threaded program

by techman2006 (Beadle)
on Jan 29, 2014 at 11:58 UTC ( [id://1072494]=perlquestion: print w/replies, xml ) Need Help??

techman2006 has asked for the wisdom of the Perl Monks concerning the following question:

How can I update a global variable across threads as I am getting garbage value for the variable across threads.

Below is sample code which shows the problem

use strict; use warnings; use threads; my $currentWrite = 10; my $totalSize = 1000; sub Progress { my $size = shift; $currentWrite += $size; my $currentProgress = $currentWrite / 100; print "Done ", $currentProgress, " of ", $totalSize, "\n"; } sub test { my $countRef = shift; my $count = $$countRef; Progress ( 11); print "Current count is $count\n"; } Progress(10); my $numThreads = 5; my @arrThreads; for my $i ( 1 .. $numThreads) { my $t = threads->create( \&test, \$i); push( @arrThreads, $t); } foreach (@arrThreads) { my $num = $_->join; }

Below is the output of above program.

# perl thrprog.pl Done 0.2 of 1000 Done 0.31 of 1000 Current count is 2 Done 0.31 of 1000 Current count is 1 Done 0.31 of 1000 Current count is 3 Done 0.31 of 1000 Current count is 4 Done 0.31 of 1000 Current count is 5

How to share the data across threads so that the value get updated properly.

Replies are listed 'Best First'.
Re: Updating global variable in multi-threaded program
by BrowserUk (Patriarch) on Jan 29, 2014 at 12:04 UTC
    How to share the data across threads so that the value get updated properly.

    Mark the shared variables as shared. See threads::shared.

    Without any testing, something like:

    use strict; use warnings; use threads; use threads::shared; my $currentWrite :shared = 10; my $totalSize = 1000; sub Progress { my $size = shift; $currentWrite += $size; my $currentProgress = $currentWrite / 100; print "Done ", $currentProgress, " of ", $totalSize, "\n"; } sub test { my $countRef = shift; my $count = $$countRef; Progress ( 11); print "Current count is $count\n"; } Progress(10); my $numThreads = 5; my @arrThreads; for my $i ( 1 .. $numThreads) { my $t = threads->create( \&test, \$i); push( @arrThreads, $t); } foreach (@arrThreads) { my $num = $_->join; }

    With the rise and rise of 'Social' network sites: 'Computers are making people easier to use everyday'
    Examine what is said, not who speaks -- Silence betokens consent -- Love the truth but pardon error.
    "Science is about questioning the status quo. Questioning authority".
    In the absence of evidence, opinion is indistinguishable from prejudice.
    li
Re: Updating global variable in multi-threaded program
by zentara (Archbishop) on Jan 29, 2014 at 12:53 UTC
Re: Updating global variable in multi-threaded program
by hdb (Monsignor) on Jan 29, 2014 at 12:20 UTC

    Besides sharing variables between threads, the documentation also explains how to lock shared variables to avoid clashes when multiple threads try to access a variable at the same time.

Log In?
Username:
Password:

What's my password?
Create A New User
Domain Nodelet?
Node Status?
node history
Node Type: perlquestion [id://1072494]
Approved by Corion
help
Chatterbox?
and the web crawler heard nothing...

How do I use this?Last hourOther CB clients
Other Users?
Others avoiding work at the Monastery: (3)
As of 2024-04-19 17:41 GMT
Sections?
Information?
Find Nodes?
Leftovers?
    Voting Booth?

    No recent polls found