use strict;
use warnings;
use IO::Select;
use IO::Socket::SSL;
use threads;
use threads::shared;
my %misc :shared;
my @dout :shared;
my %outputs :shared;
threads->create('pool');

my $connection = IO::Socket::SSL->new(PeerHost => 'local.btc-node', 
                                      PeerPort => 7566, Proto=> 'tcp')
+ or die($!);

my $_sel = IO::Select->new;
$_sel->add($connection);
$connection->blocking(0);

while(1)
 {
  my ($readable, undef, undef) = IO::Select->select($_sel, undef, $_se
+l, 0.21);
       if(scalar keys %outputs > 0)
       {
              foreach my $__a (keys %outputs){
                foreach my $_line (@dout){
                     $_line =~ s/[\r\n]+//g;
                     next if $_line eq '';
                     $connection->print("$_line\n");
                }
                delete $outputs{$__a};
        }
     }
  foreach my $socket (@$readable)
   {
    my $n = sysread($socket,my $msg,4096);
    if(defined $n)
     {
        if($msg =~ /tick\s+([^\d\s\t]+)/)
         {
            my $currency = $1;
            tick ($currency);
         }
     }
    }
 }



    
sub tick {
my $currency = shift;
$misc{arg} = $currency;
}

sub pool {
 while(1){
    my $thread = threads->create(t) if defined $misc{arg};
    select(undef, undef, undef, 0.52);
    foreach(threads->list){ undef $misc{arg}; $_->detach(); }
 }
}

sub t{
 @dout="hi $misc{arg}";
 $outputs{int(rand 500)}=1;
}
[download]