Beefy Boxes and Bandwidth Generously Provided by pair Networks
Pathologically Eclectic Rubbish Lister
 
PerlMonks  

comment on

( #3333=superdoc: print w/replies, xml ) Need Help??

Hi again! BrowserUk's demo is possible for Perl lacking threads support. A condition variable is needed to prevent a race condition, especially for processes that spawn quickly. For example, the 2nd worker attempting to connect before the 1st worker initiates the connection.

#! perl -slw # Parallel example for Perl not built with threads support. # Based on https://www.perlmonks.org/?node_id=897591. use strict; use Time::HiRes qw[ time usleep ]; use MCE::Hobo; use MCE::Shared; use IO::Socket; our $port //= 12345; my $condvar = MCE::Shared->condvar; my $svrN = MCE::Shared->scalar( 0 ); my $clientN = MCE::Shared->scalar( 0 ); my $is_winenv = ( $^O =~ /mswin|mingw|msys|cygwin/i ); my $start = time; mce_async { my $svr = IO::Socket::INET->new( Listen => SOMAXCONN, Reuse =>1, LocalPort => $port, Timeout => 0.1, ) or die $!; # signal the client ready $condvar->signal; while( my $client = $svr->accept ) { my $in = <$client>; print $client "echod:$in"; syswrite($client, '0') if $is_winenv; $client->shutdown( 2 ); close $client; $svrN->incr; } }; mce_async { # wait for the server connection $condvar->wait; while( 1 ) { my $svr = IO::Socket::INET->new( PeerHost => 'localhost', PeerPort => $port, Reuse => 1, Timeout => 0.1, ) or usleep( 10_000 ), next; sleep 0; print $svr $clientN->incr; my $echo = <$svr>; sleep 0; syswrite($svr, '0') if $is_winenv; $svr->shutdown( 2 ); close $svr; sleep 0; } }; $|++; while( usleep 100_000 ) { my ( $n1, $n2 ) = ( $svrN->get, $clientN->get ); printf "\rserver:$n1 client:$n2 cycles: %.3f/sec", $n1 / ( time() - $start ); }

Note: MCE::Shared involves sockets. So it will not run as fast as threads::shared. Not to worry, it's not far behind.

Strawberry Perl

Y:\>perl demo_thr.pl server:29889 client:29889 cycles: 2119.429/secTerminating on signal SI +GINT(2) Y:\>perl demo_mce.pl server:35619 client:35620 cycles: 1771.711/secTerminating on signal SI +GINT(2)

Cygwin

$ perl demo_thr.pl server:31879 client:31879 cycles: 2128.663/sec $ perl demo_mce.pl server:31690 client:31691 cycles: 1856.834/sec

Regards, Mario


In reply to Re^2: Socket hang. (Windows or Perl? Solutions?) (Updated) by marioroy
in thread Socket hang. (Windows or Perl? Solutions?) (Updated) by BrowserUk

Title:
Use:  <p> text here (a paragraph) </p>
and:  <code> code here </code>
to format your post; it's "PerlMonks-approved HTML":



  • Posts are HTML formatted. Put <p> </p> tags around your paragraphs. Put <code> </code> tags around your code and data!
  • Titles consisting of a single word are discouraged, and in most cases are disallowed outright.
  • Read Where should I post X? if you're not absolutely sure you're posting in the right place.
  • Please read these before you post! —
  • Posts may use any of the Perl Monks Approved HTML tags:
    a, abbr, b, big, blockquote, br, caption, center, col, colgroup, dd, del, div, dl, dt, em, font, h1, h2, h3, h4, h5, h6, hr, i, ins, li, ol, p, pre, readmore, small, span, spoiler, strike, strong, sub, sup, table, tbody, td, tfoot, th, thead, tr, tt, u, ul, wbr
  • You may need to use entities for some characters, as follows. (Exception: Within code tags, you can put the characters literally.)
            For:     Use:
    & &amp;
    < &lt;
    > &gt;
    [ &#91;
    ] &#93;
  • Link using PerlMonks shortcuts! What shortcuts can I use for linking?
  • See Writeup Formatting Tips and other pages linked from there for more info.
  • Log In?
    Username:
    Password:

    What's my password?
    Create A New User
    Chatterbox?
    and the web crawler heard nothing...

    How do I use this? | Other CB clients
    Other Users?
    Others surveying the Monastery: (4)
    As of 2019-11-21 08:13 GMT
    Sections?
    Information?
    Find Nodes?
    Leftovers?
      Voting Booth?
      Strict and warnings: which comes first?



      Results (104 votes). Check out past polls.

      Notices?