use strict ;
use warnings ;

use MCE::Hobo ;
use MCE::Shared ;

use Data::Dumper ;

sub task1 {
	print "Starting task 1 for $_[0]\n" ;
	sleep(2) ;
	print "Finished task 1 for $_[0]\n" ;
}

sub task2 {
	print "Starting task 2 for $_[0]\n" ;
	sleep(4) ;
	print "Finished task 2 for $_[0]\n" ;
}

sub task3 {
	print "Starting task 3 for $_[0]\n" ;
	sleep(6) ;
	print "Finished task 3 for $_[0]\n" ;
}

MCE::Hobo->init(
	max_workers => 2,
# 	hobo_timeout => 10,
# 	posix_exit => 1,
) ;

my $mutex = MCE::Mutex->new;

my $_test = {
	L1_counter1 => 1,
	# L1_counter2 => 2,
	# L1_counter3 => 3,
	nested1 => {
		L2_counter1 => 3,
		# L2_counter2 => 2,
		# L2_counter3 => 1,
	},
} ;

my $test ;
tie %{$test}, 'MCE::Shared', { module => 'MCE::Shared::Hash' }, %{$_test} ;
print Dumper( $test ) ;

sub executeTasks {
	my $in = $_[0] ;
	my $hobo ;
	foreach( keys %{$in} ) {
		if ( ref $in->{ $_ } eq 'HASH' ) {
			executeTasks( $in->{ $_ } ) ;
		} else {
			if ( $in->{ $_ } == 1 ) {
				$hobo = mce_async {
					task1( $_ ) ;
					++$in->{ $_ } ;
				} ;
			} elsif ( $in->{ $_ } == 2 ) {
				$hobo = mce_async {
					task2( $_ ) ;
					++$in->{ $_ } ;
				} ;
			} elsif ( $in->{ $_ } == 3 ) {
				$hobo = mce_async {
					task3( $_ ) ;
					++$in->{ $_ } ;
				} ;
			} ;
		} ;
	} ;
	$hobo->join() ;
} ;
executeTasks( $test ) ;
print "\n" ;
print Dumper( $test ) ;