#ignore child processes to prevent zombies
$SIG{CHLD} = 'IGNORE';

##</code><code>##

threads->create ("read_data", $queue, $connection)->detach;

##</code><code>##

sub read_data {
    # accept data from the socket and put it on the queue
    my ($queue, $socket) = @_;
    while (<$socket>) {
        print "listener got: $_";
        $queue -> enqueue(time." $_");
    }
    close $socket;
}