发新话题
打印

php stream_set_blocking让程序无阻塞

php stream_set_blocking让程序无阻塞

stream_set_blocking ($resource, $flag); $flag 取值为0或1 0是非阻塞,1是阻塞 阻塞的意义是什么呢? 某个函数读取一个网络流,当没有未读取字节的时候,程序该怎么办? 是一直等待,直到下一个未读取的字节的出现,还是立即告诉调用者当前没有新内容? 前者是阻塞的,后者是非阻塞的。 阻塞的好处是,排除其它非正常因素,阻塞的是按顺序执行的同步的读取。 借用小说里的说法就是“神刀出鞘,无血不归”。在读到新内容之前,它不会往下走,什么别的事情都不做。 而非阻塞,因为不必等待内容,所以能异步的执行,现在读到读不到都没关系,执行读取操作后立刻就继续往下做别的事情。 如果你不放心,可以过一定的时间再来检查执行的结果。之前我写过一个用popen pclose来让程序并发执行的例子。 当时的遗憾就是调用之后不管,所以没法知道程序是否执行成功了。现在popen之后设定为非阻塞模式,就可以创建一个数组作为任务池。 使用一个while(1)的“死循环”来检查当前任务池中各个任务的状态,有老任务执行完毕时,$status = stream_get_meta_data($resource); 状态值$status['eof']为真,就表示那个任务执行完毕了。我本次实现的程序功能比较单一,只需要知道它执行完毕就可以了。如果你的任务有多种结果,那就继续分析读取到的内容吧。发现有任务执行完毕,从任务池中剔除该任务,如果任务队列中还有未做的任务,就把新任务从队列中移到任务池中执行。

TOP

发新话题