#!/usr/bin/perl -- use strict; use warnings; use threads stack_size => 4096; use IO::Socket::INET; use Time::HiRes qw/ usleep /; use Data::Dump qw/ dd /; Main( @ARGV ); exit( 0 ); sub Main { my $host = "localhost:" . int( rand 99999 ); Dodo( $host, 'IO::Socket::INET' ); ## "works" ## Dodo( $host, 'IO::Socket::SSL' ); use IO::Socket::SSL; ## "doesn +'t" } ## end sub Main sub Dodo { my( $host, $socktype ) = @_; async( \&Server, $host, $socktype ); sleep 1; my $socket = $socktype->new( Proto => "tcp", PeerHost => $host, ) or die "Cannot start client : $!\n $@\n "; $socket->blocking( 0 ); async( \&Reader, $socket ); async( \&Writer, $socket ); $_->join for threads->list; } ## end sub Dodo sub Server { my( $host, $socktype ) = @_; my $tid = threads->tid; use Time::HiRes qw/ usleep /; my $server = $socktype->new( Proto => "tcp", LocalHost => $host, Listen => 1, Reuse => 1, ) or die "Cannot start tcp server: $!\n $@\n "; dd "listening on $host\n"; sleep 1; my $client = $server->accept(); while( <$client> ) { dd "echo reader($tid) $_"; print $client "echo reader($tid) $_"; last if /exit/i; } ## end while( <$client> ) } ## end sub Server sub Writer { my( $socket ) = @_; my $tid = threads->tid; for( 1 .. 20 ) { usleep 2000 * rand( 500 ); # 2000 sleep for 2 millisecond $socket->print( "writer($tid) " . scalar( gmtime ) . "\n" ); } ## end for( 1 .. 20 ) $socket->shutdown( 1 ); ## done writing } ## end sub Writer sub Reader { my( $socket ) = @_; my $tid = threads->tid; my $read = 0; while( $read < 1000 ) { my $readed = $socket->sysread( my $line, 51 ); next if !$readed; $read += $readed; dd "holymolyreaded($read/$readed) $line"; usleep 2000 * rand( 500 ); } ## end while( $read < 1000 ) $socket->print( "reader($tid) " . scalar( gmtime ) . " exit\n" ); } ## end sub Reader __END__
In reply to Re: Can I/O operations on the same IO::Socket be executed in different threads?
by Anonymous Monk
in thread Can I/O operations on the same IO::Socket be executed in different threads?
by Anonymous Monk
| For: | Use: | ||
| & | & | ||
| < | < | ||
| > | > | ||
| [ | [ | ||
| ] | ] |