Sponsored Content
Full Discussion: using threads in perl
Top Forums Shell Programming and Scripting using threads in perl Post 302629951 by free2rhyme2k on Wednesday 25th of April 2012 05:38:49 PM
Old 04-25-2012
using threads in perl

Hi everyone,

I am trying to create a script which runs a number of processes simultaneously and at the same time use a timer to keep track of what is going on.

The problem is that the timer stops and the script exits upon the completion of some of the processes, whereas I want to timer to continue indefinitely.

Note that the functionality of the file transfer and file size monitoring all works as required, the problem is only with the timer not continuing after the file has been completely sent. I want to add subsequent files so it is important that the timer continues.

Here is some code:
Code:
#!/usr/bin/perl
use strict;
use warnings;
use threads;
use Time::HiRes qw(usleep nanosleep);

my @downloadingFiles = ();
my $fileNumber = 0;
my $overallTimer = 0;
my $fileSize = 0;
my $temp1 = 0;
my $temp2 = 0;

#this is my timer which should run until 1000, but it actually stops when setupSenderAndReceiver function has terminated. It is monitoring the file size of the file which is being transferred through the socket.
sub GlobalTimer	{
	while($overallTimer <= 1000)	{
	$overallTimer++;
	sleep(1);
	$fileSize = -s "out$fileNumber";
	@downloadingFiles[$fileNumber] = $fileSize;
        $print "$overallTimer";
					}
		}

#this function uses two functions inside it to establish a server and client connection and send a file through a socket.
sub setupSenderAndReceiver{
$temp1 = $_[0];
$temp2 = $_[0];

#this script opens the server port
sub first {
system("/usr/bin/perl myPerlScript2.pl $temp1");
}

#this sends a command to a remote machine to start sending data.
sub second {
my @x = ("bash", "-c", "ssh ip_address_and_details_removed $temp2");
system(@x);
}

#this should instruction both processes to run at the same time and exit the thread upon completion.
my $firstThread = threads->create(\&first);
my $secondThread = threads->create(\&second);
firstThread->join();
secondThread->join();
}

#this is the thread I used to start the overall timer
my $globalT = threads->create(\&GlobalTimer);
$globalT->detach();
#this is the thread I used to create the file transfer
my $start = threads->create(\&setupSenderAndReceiver, $fileNumber);
$start->join();

Thanks in advance.

---------- Post updated at 04:38 PM ---------- Previous update was at 07:26 AM ----------

Uppies
 

10 More Discussions You Might Find Interesting

1. Post Here to Contact Site Administrators and Moderators

old threads

Neo, if I have an old thread that is a few months old, and a few pages back in the forum it was posted in, is it ok to 'bump' it back to the front? or, would you rather i deleted the old thread, and just create a new one? btw the thread has no replies. (2 Replies)
Discussion started by: norsk hedensk
2 Replies

2. UNIX for Dummies Questions & Answers

threads

i am tring to sort lots of data thats in many columns by just one column but, if I use sort +16 inputfile the column fluctuates because some of the rows have spaces etc within the text, so the end result is just a mess as it jumps around the columns depending whether it has spaces or not ....ie... (2 Replies)
Discussion started by: Gerry405
2 Replies

3. Solaris

threads

Hi all! 1)Is there a way to write a program that will work on both solaris and intel based machines. 2)How can I achive this for a program that creates and synchronizes three threads. Thank you. vij. (3 Replies)
Discussion started by: vijlak
3 Replies

4. Shell Programming and Scripting

new to perl.. how do I do this ? fork/ threads ?

I have never coded in perl before (just started today morning :). I need to write a perl program to automate a task. Here is how I do it manually: Start a program in my home dir. Now if I want to execute another program while this one is still running, what I would do is go to another... (6 Replies)
Discussion started by: the_learner
6 Replies

5. UNIX for Advanced & Expert Users

How many threads do I use ?

Hi, I have a program that has two types of threads: 1) Reader threads 2) Worker Threads Readers: Their only job is to read files. They just read data from the files and put them into a buffer. They are obviously I/O intensive. Workers: These are CPU intensive. They do some computation... (5 Replies)
Discussion started by: the_learner
5 Replies

6. UNIX for Advanced & Expert Users

Threads and Threads Count ?

Hi all, How can I get the list of all Threads and the Total count of threads under a particular process ? Do suggest !! Awaiting for the replies !! Thanks Varun:b: (2 Replies)
Discussion started by: varungupta
2 Replies

7. Programming

Threads help

Hello! I started studying studying about POSIX Threads a few days ago... so I am a little confused and I would appreciate some help! I isolated this code... and I wonder if I could use threads in it! #include <unistd.h> #endif #include <math.h> //#include "main.h" #include <sys/time.h>... (1 Reply)
Discussion started by: smurf2
1 Replies

8. Shell Programming and Scripting

Perl v5.8.5 Threads Problem

Hi Unix gurus, I am facing a threading problem in Perl. I have a worker thread in perl in which I am calling a shell script. The shell script echo's output to the Standard Output from time to time as it progresses. In the worker thread, I am unable to display the echo statement of shell... (1 Reply)
Discussion started by: som.nitk
1 Replies

9. Shell Programming and Scripting

perl launch threads in an array variable?

Im having a problem launching multiple sub routines as threads. My script seems to stop when the first thread is launched. Im condensing the code for simplification here: #!/usr/bin/perl -w use strict; use threads; srand; my ($cnt,$line,$iprange_rand); my... (2 Replies)
Discussion started by: trey85stang
2 Replies

10. Shell Programming and Scripting

Perl Threads Terminating Abnormally.

I've used threads before, but not with Perl. I tried looking up these errors and using 'join' instead of 'detach' with no luck. Here is the code I am currently using: #!/usr/bin/perl -w use warnings; use threads; use threads::shared; $Linux='Linux'; $Greek='Greek'; my... (3 Replies)
Discussion started by: Azrael
3 Replies
getitimer(2)							System Calls Manual						      getitimer(2)

NAME
getitimer(), setitimer() - get and set value of interval timer SYNOPSIS
DESCRIPTION
The function stores the current value of the timer specified by which into the structure pointed to by value. The function sets the timer specified by which to the value specified in the structure pointed to by value, and if ovalue is not a null pointer, stores the previous value of the timer in the structure pointed to by ovalue. The header declares the structure: If it_value is non-zero, it indicates the time to the next timer expiration. If it_interval is non-zero, it specifies a value to be used in reloading it_value when the timer expires. Setting it_value to 0 disables the timer, regardless of the value of it_interval. Setting it_interval to 0 disables the timer after its next expiration (assuming it_value is non-zero). Implementations may place limitations on the granularity of timer values. For each interval timer, if the requested timer value requires a finer granularity than the implementation supports, the actual timer value will be rounded up to the next supported value. Timer values smaller than the resolution of the system clock are rounded up to this resolution. The machine-dependent clock resolution is seconds, where the constant is defined in To make sure that a process gets at least as much time as requested, the timer value is rounded up to the next timer tick (a timer tick is the smallest supported value). The timer value is rounded up to the next timer tick, because the timer may be initialized somewhere between timer ticks. If a is followed by a without a timer tick in between, it is possible that the value returned by may be more than the initial value requested by due to this rounding. Implementations may place limitations on the timer value. Timer values larger than an implementation-specific maximum value are rounded down to this maximum. The maximum values for the three interval timers are specified by the constants and defined in On all implementa- tions, these values are guaranteed to be at least 31 days (in seconds). An XSI-conforming implementation provides each process with at least three interval timers, which are indicated by the which argument: Decrements in real time. A signal is delivered to the process when this timer expires. Decrements in process virtual time. This timer runs only when the process is executing. A signal is delivered to the process when the timer expires. Decrements both in process virtual time and when the system is running on behalf of the process. This timer is designed to be used by interpreters in sta- tistically profiling the execution of interpreted programs. Each time the timer expires, a signal is delivered to the process. In addition to the above timers, HP-UX provides the following three per-thread interval timers for threads, which are indicated by the which argument: Decrements in real time. A signal is delivered to the thread which set this timer when the timer expires. Decrements in thread virtual time. This timer runs only when the thread is executing. A signal is delivered to the thread which set this timer when the timer expires. Decrements both in thread virtual time and when the system is running on behalf of the thread. Each time the timer expires, a signal is delivered to the thread which set this timer. Since a signal can interrupt in-progress system calls, programs using this timer must be prepared to restart the interrupted system call. Interval timers are not inherited by a child process across a but are inherited across an Three macros for manipulating time values are defined in Set a time value to zero. Test if a time value is non-zero. Compare two time values. (Beware that and do not work with the macro.) The timer used with is also used by (see alarm(2)). Thus successive calls to and set and return the state of a single timer. In addition, a call to sets the timer interval to zero. The interaction between and any of or is unspecified. RETURN VALUE
Upon successful completion, or returns 0. Otherwise, -1 is returned and is set to indicate the error. ERRORS
The function will fail if: The value argument is not in canonical form. (In canonical form, the number of microseconds is a non-negative integer less than 1,000,000 and the number of seconds is a non-negative integer.) The and functions may fail if: The which argument is not recognized. The value structure specified a bad address. Reliable detection of this error is implementation dependent. EXAMPLES
The following call to sets the real-time interval timer to expire initially after 10 seconds and every 0.5 seconds thereafter: AUTHOR
was developed by the University of California, Berkeley. SEE ALSO
alarm(2), exec(2), ualarm(2), usleep(2), pthread_attr_setscope(3T), pthread_create(3T), pthread_sigmask(3T), sleep(3C), signal(5). CHANGE HISTORY
First released in Issue 4, Version 2. getitimer(2)
All times are GMT -4. The time now is 07:01 PM.
Unix & Linux Forums Content Copyright 1993-2022. All Rights Reserved.
Privacy Policy