use DBI; use threads qw(stringify); use threads::shared; use Time::HiRes qw (sleep); do("./sql.pl"); &sql_setup; $server_id = "A"; share($server_id); $sys_ok = 1; share($sys_ok); $|++; $thr1 = threads->new(\&starter); $thr1->detach; $thr2 = threads->new(\&stopper); $thr2->detach; $thr3 = threads->new(\&monitor); $thr3->detach; $thr4 = threads->new(\&processor); $thr4->detach; #### sub row_sql(){ my $select = $_[0]; my @row2,$dbh2,$sth2; if ($select eq ""){print "Empty Select."; exit;} $dbh2=DBI->connect($connectionInfo,$user,$passwd) || print "DBI Connection Failed!($DBI::errstr)"; $sth2=$dbh2->prepare($select); if (!($sth2->execute())) { } @row2=$sth2->fetchrow_array(); $sth2->finish; $dbh2->disconnect(); return (@row2); }