Форум работает только в режиме чтения!
Регистрация новых пользователей закрыта.
Просмотр сообщений
В этом разделе можно просмотреть все сообщения, сделанные этим пользователем.
?
use strict;
require Win32::ChangeNotify;
my $Path=\'D:\\DATA\';
my $WatchSubTree=1;
my $Events=\'LAST_WRITE\';
my $objNotify=Win32::ChangeNotify->new($Path,$WatchSubTree,$Events);
while (1) {
$objNotify->wait();
print "Something changed\\n";
$objNotify->reset();
}
$objNotify->close();
use strict;
require Win32::ChangeNotify;
my $Path=\'D:\\DATA\';
my $WatchSubTree=1;
my $Events=\'LAST_WRITE\';
my $notify=Win32::ChangeNotify->new($Path,$WatchSubTree,$Events);
$notify->wait();
print "Something changed\\n";
use strict;
use Thread qw(async yield);
my $var = 0;
sub child {
{
lock $var;
if ($var == 0) {
yield;
$var++;
print "var is $var\\n";
}
}
}
my $t2 = new Thread \\&child;
$t2->join;
print "var is $var\\n";
my $i = 0;
for ($i; $i<=10 ; $i++) {
Time::HiRes::sleep(1.0);
}
use IO::Handle;
use strict;
my $threads = 5;
pipe(READER, WRITER);
autoflush WRITER;
my ($pid, $line);
my $threads = 5;
for (my $i = 1; $i <= ($threads); $i++) {
if ($pid = fork) {
close WRITER;
chomp($line = );
#print $line;
close READER;
waitpid($pid,0);
}
else {
die "cannot fork: $!" unless defined $pid;
close READER;
print WRITER "4"; #This value will be sent to $line
close WRITER; # this will happen anyway
exit;
}
}
print $line;
use strict;
use Benchmark;
my $tmStamp1 = new Benchmark;
#/////////////////////////////////////////////////////////////////////////////////
$| = 1;
my $threads = 5;
my @pids;
my $isExit = 0;
#/////////////////////////////////////////////////////////////////////////////////
for (1 .. $threads) {
makeChild();
}
print "$isExit\\n";
for (my $i = 0; $i <= ($threads-1); $i++) {
print "$pids[$i]\\n";
waitpid($pids[$i], 0);
}
print "$isExit\\n";
#/////////////////////////////////////////////////////////////////////////////////
my $tmStamp2 = new Benchmark;
my $tmDiffer = timediff($tmStamp1, $tmStamp2);
print timestr($tmDiffer);
#/////////////////////////////////////////////////////////////////////////////////
sub makeChild {
my $pid;
die "fork: $!" unless defined ($pid = fork);
if ($pid) {
push(@pids,$pid);
return;
}
else {
my $i = 0;
for ($i; $i<=10 ; $i++) {
Time::HiRes::sleep(1.0);
}
$isExit = 1;
exit(0);
}
}
#/////////////////////////////////////////////////////////////////////////////////
use strict;
use IO::Socket;
my $rem_port = 2967;
my $proto = \'udp\';
my $send_msg = "\\x00\\xCE\\x00\\x00\\x00\\xC0\\x01\\x01\\x00\\x00\\x00\\x00\\xDA\\x49\\x1F\\x10";
my $size_msg = 466;
my $objSocket = IO::Socket::INET->new(PeerAddr => \'172.17.242.1\', PeerPort => $rem_port, Proto => $proto, Type => SOCK_DGRAM, Timeout => 5);
$objSocket->send($send_msg);
$objSocket->recv(my $recv_msg, $size_msg);
if (length($recv_msg) > 0) {
print "Is OK!\\n";
}
else {
print "Is bad!\\n";
}
$objSocket->shutdown(2);