my %listerners;

sub create_new_listener {
   my ($param) = @_;

   my $queue  = Thread::Queue->new();
   my $thread = threads->new(\&listen, $param, $queue);

   $listeners{$param} = [ $thread, $queue ];
}