phpstream_select兑现可控并发

";
                                fclose($r);
                                unset($sockets[$index]);
                                //add new task
                                $next = $id++;
                                if($next < $time){
                                        $s = stream_socket_client($url,$errno,$errstr,$timeout,STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT);
                                        $sockets[$next] = $s;
                                        fwrite($s,sprintf($http_msg,$id));
                                }
                        }
                }
        }
}





?>