sub OnTaskEnd {
	my ($forksuperjob, $jobid) = @_;
	if (ref($forksuperjob) ne 'Forks::Super::Job') {
		die("OnTaskEnd called with argument of type [" . ref($forksuperjob) . "] instead of expected Forks::Super::Job");
	}
	print("TaskEnd: JobID [$jobid] Job pid [" . $forksuperjob->{real_pid} . "] starttime [" . int($forksuperjob->{start}) . "] name [" . $forksuperjob->{name} . "] status [" . $forksuperjob->{status} . "]\n");
	# Do other stuff here, like starting new jobs to process files
	$forksuperjob->dispose;
}

foreach my $val1 (@array1) {
	my $forkresult = Forks::Super::fork {
		dir => 'dir_here',
		cmd => 'your_command_here.pl',
		name => 'unique_name_of_task',
		callback => {
			start => \&OnTaskStart,
			finish => \&OnTaskEnd
		},
	};
}
print("Waiting for child jobs to finish\n");
my $jobs_waited = waitall();
print("[$jobs_waited] jobs were scheduled/running and have now finished\n");