#! perl -slw
use strict;
use threads;
use Thread::Queue;
use Data::Dumper;

our $QMAX ||= 1000;
our $TMAX ||= 3;
our $N	  ||= 1000000;

my $Q = new Thread::Queue;

sub thread {
	my $tid = threads->self->tid;
	for( 1 .. $N ) {
		$Q->enqueue( join ':', $tid, int rand( 10 ) );
		select undef, undef, undef, 0.01 while $Q->pending > $QMAX;
	}
	$Q->enqueue( undef );
}

threads->new( \&thread )->detach for 1 .. $TMAX;

my %collate;
for ( 1 .. $TMAX ) {
	while( my $data = $Q->dequeue() ) {
		my( $src, $value ) = split ':', $data;
		$collate{ $src }{ $value }++;
	}
}

print Dumper \%collate;