生产者与消费者模式

<?php
//生产者，每秒钟向queue写入一个数字
$n = 1;
while(1){
    echo $n.chr(10);
    file_put_contents('queue', $n.chr(10));
    $n++;
    sleep(1);
}

//end

<?php
//消费者
$file = 'queue';
while (1){
    if(is_file($file)){
        $tmp_file = 'queue_tmp';
        rename('queue', $tmp_file);//重命名文件，保证在读取不被生产者程序干扰
        //读取文件，进行处理
        $content = file($tmp_file);
        foreach ($content as $value){
            echo $value;//输出结果
        }
        unlink($tmp_file);
    }
    sleep(1);
}

//end