I tested it myself with two clients and got this output:use strict; use threads; use threads::shared; use IO::Socket; my $keep_running : shared = 1; my $sender_thread = threads->new(\&do_send); my $listener_thread = threads->new(\&do_listen); $sender_thread->detach(); $listener_thread->join(); sub do_listen { my $listener_sock = IO::Socket::INET->new(LocalHost => "127.0. +0.1", LocalPort => 8080, Type => SOCK_STREAM, Proto => 'tcp', Listen => 1); my $client_sock; my $ClientNumber = 0; STDOUT->autoflush(1); print "Starting listener\n"; while ($keep_running) { my $client_sock = $listener_sock->accept(); my $reader_thread = threads->new(\&do_read, $client_so +ck, $ClientNumber); last unless defined($client_sock); $ClientNumber++; $reader_thread->detach(); print "Accepted a connection\n"; } print "Listener stopped\n"; } sub do_read { my $sock = shift; my $ClientNumber = shift; while (<$sock>) { print $ClientNumber . ":" . $_; } print "Client " . $ClientNumber . " disconnected\n"; } sub do_send { # any messages that the local user types while (my $line = <STDIN>) { # TODO: you need to iterate through all active clients and sen +d them # , not just one # $sock->print($line); # $sock->flush(); # patch for development sleep 1; } $keep_running = 0; }
Starting listener Accepted a connection 0:hi Accepted a connection 1:hi 0:Yo #1 1:Whaddup #0!
In reply to Re: How to do simultaneous reads and writes to/from a socket?
by MonkE
in thread How to do simultaneous reads and writes to/from a socket?
by sonofason
| For: | Use: | ||
| & | & | ||
| < | < | ||
| > | > | ||
| [ | [ | ||
| ] | ] |