#!/usr/bin/perl

use strict;
use warnings;
use threads;
use threads::shared;

use Socket::Class;

our $RUNNING : shared = 1;

our $Server = Socket::Class->new(
    'local_addr' => '127.0.0.1',
    'local_port' => '7777',
    'listen'     => 5,
    'blocking'   => 0,
    'reuseaddr'  => 1,
) or die Socket::Class->error;

$SIG{'INT'} = \&quit;

threads->create( \&server_thread, $Server );
threads->create( \&client_thread, $Server );
while ($RUNNING) {
    $Server->wait(5);

}

sub quit {
    my ($thread);
    $RUNNING = 0;
    foreach $thread ( threads->list ) {
        eval { $thread->join(); };
    }
    $Server->free();
    exit(0);
}

sub server_thread {
    my ($server) = @_;
    my ($client);
    print "Server running at port: ", $server->local_port, "\n";
    while ($RUNNING) {
        $client = $server->accept();
        if ( !defined $client ) {
            last;
        }
        elsif ( !$client ) {
            next;
        }
        threads->create( \&client_thread, $client );
    }
    return 1;
}

sub client_thread {
    my ($client) = @_;
    my ( $buf, $got );
    print 'Client is running on port ' . $client->remote_port . "\n";
    $client->wait(5);
    $client->free();
    threads->self->detach() if $RUNNING;
    return 1;
}
quit();