my $server = threads::Server->new(
     LocalPort => 9000,
     Pool => 5,
     Accept => sub {
         printf "Accepted connection from %s:%d on port:%d\n",
            $_->peerhost, $_->peerport, $_->sockport;
         return;
     },
    Thread => sub {
        my( $client, $Qout, @args ) = @_;
        while( <$client> ) {
            chomp;
            ##1 warnf "Got '%s'\n", $_;
            $Qout->enqueue( $_ );
            print $client 'Ack';
        }
    },
    Common => sub {
        my $Q = shift;
        while( $Q->dequeue() ) {
            #1 warnf "Processing '$_'";
        }
    },
);

$server->Run;