Woa... Way not enough information. What OS is the code running on? I assume we're talkin itheads? Are you using join() or detach()? Are the worker threads doing system calls? Writing to disk? What do you mean by interupted?

In general the worker threads have to finish, ie. exit normally, before join() and detach() can clean up.

From perlthrtut

"Similarly, mixing signals and threads should not be attempted."

         use File::Temp qw/ tempfile tempdir /;

         $dir = tempdir( CLEANUP => 1 );
[download]

Also, please post some sample code so we can see just want you're doing.

Here's a simple code snippet that replicates the behavior. The program creates a job queue with 10 jobs and has 4 workers act on those. The jobs are sleeps from 0-5 sec. If you let the program run to completion, it prints "workers done" and then "END block executed". If you interrupt it with ^C you get nothing, not even an error message.

#!/usr/bin/perl
use strict; use warnings;
use threads;
use Thread::Queue;

my $Q = new Thread::Queue;
for (my $i = 0; $i < 10; $i++) {$Q->enqueue(int rand 6)}
my @worker;
for (my $i = 0; $i < 4; $i++) {$worker[$i] = threads->create(\&worker, $Q)}
for (my $i = 0; $i < 4; $i++) {$worker[$i]->join}
print STDERR "workers done\n";

sub worker {
	my ($q) = @_;
	my $tid = threads->tid;
	while ($q->pending) {
		my $job = $q->dequeue;
		print STDERR "processing sleep($job) in thread $tid\n";
		sleep($job);
	}
}

END {
	print STDERR "END block executed\n";
}

Try this.

#!/usr/bin/perl
use strict; use warnings;
use threads;
use Thread::Queue;

$SIG{ INT } = sub{
    print "Interupted\n";
    exit;
};

my $Q = new Thread::Queue;
for (my $i = 0; $i < 10; $i++) {$Q->enqueue(int rand 6)}
my @worker;
for (my $i = 0; $i < 4; $i++) {$worker[$i] = threads->create(\&worker,
+ $Q)}
for (my $i = 0; $i < 4; $i++) {$worker[$i]->join}
print STDERR "workers done\n";

sub worker {
    my ($q) = @_;
    my $tid = threads->tid;
    while ($q->pending) {
        my $job = $q->dequeue;
        print STDERR "processing sleep($job) in thread $tid\n";
        sleep($job);
    }
}


END {
    print STDERR "END block executed\n";
}
__END__
c:\test>560021.pl
processing sleep(0) in thread 1
processing sleep(4) in thread 1
processing sleep(1) in thread 2
processing sleep(0) in thread 3
processing sleep(1) in thread 3
processing sleep(4) in thread 4
processing sleep(3) in thread 2
processing sleep(5) in thread 3
processing sleep(3) in thread 1
processing sleep(2) in thread 2
Interupted
END block executed
[download]

---

Examine what is said, not who speaks -- Silence betokens consent -- Love the truth but pardon error.

Lingua non convalesco, consenesco et abolesco. -- Rule 1 has a caveat! -- Who broke the cabal?

"Science is about questioning the status quo. Questioning authority".

In the absence of evidence, opinion is indistinguishable from prejudice.

sub sigint {
    die "Dying.";
}
$SIG{INT} = \&sigint;
[download]

$ perl test.pl
processing sleep(0) in thread 1
processing sleep(1) in thread 1
processing sleep(3) in thread 3
processing sleep(0) in thread 4
processing sleep(2) in thread 4
processing sleep(4) in thread 2
processing sleep(0) in thread 1
processing sleep(3) in thread 1
processing sleep(4) in thread 4
processing sleep(5) in thread 3
<C-c>
Dying. at test.pl line 25.
END block executed
A thread exited while 3 threads were running.
[download]

Many thanks jrockway and BrowserUk.