#!/usr/bin/env perl

use strict;
use warnings;

use MCE::Flow;
use IO::Socket;

my $nthreads = 20;
my $in_file2 = 'rang.txt';

sub ip_checker {
    my $ip = $_;
    chomp($ip);
    my $host = IO::Socket::INET->new(
        PeerAddr => $ip,
        PeerPort => 80,
        proto    => 'tcp',
        Timeout  => 1
    );
    if ( defined $host ) {
        MCE->gather($ip);
    }
}

my @result = MCE::Flow->run_file(
    { chunk_size => 1, max_workers => $nthreads },
    \&ip_checker,
    $in_file2,
);

MCE::Flow->finish();

open( my $output, ">", "port.txt" ) or die $!;
print {$output} "$_\n" for @result;
close($output);

##</code><code>##

use strict;
use warnings;

use MCE::Flow;
use IO::Socket;

my $nthreads = 20;
my $in_file2 = 'rang.txt';
open( my $output, ">", "port.txt" ) or die $!;

sub ip_checker {
    my $ip = $_;
    chomp($ip);
    my $host = IO::Socket::INET->new(
        PeerAddr => $ip,
        PeerPort => 80,
        proto    => 'tcp',
        Timeout  => 1
    );
    if ( defined $host ) {
        MCE->print($output, "$ip\n");
    }
}

MCE::Flow->run_file(
    { chunk_size => 1, max_workers => $nthreads },
    \&ip_checker,
    $in_file2,
);

MCE::Flow->finish();
close($output);