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