生产者与消费者的代码故事。

任务队列

Method 1

读取任务队列中的内容

loop
  $task = RPOP queue
  if $task
    execute $task
  else
    wait 1s

每一秒都有调用命令来查看是否有新任务，实际上这种方式的效率是很低的。

可否建立消息通知功能，每有新的任务，通知消费者来执行任务。

借助BRPOP就可以实现这样的功能。

BRPOP: 当列表中没有元素时，BRPOP命令会一直阻塞住连接，直到有新元素加入。

Method 2

修改的代码：

$task = BRPOP queue, 0
execute $task[1]

同理于BLPOP & RPUSH

优先级队列

由于BRPOP可以一次执行多个键，借此特性可以制作优先级队列

loop
  $task = 
    BRPOP queue.confirmation.email,
          queue.notification.email,
          0
  execute $task[1]

两个queue互不影响，那么一个线程就可以监听两个队列的内容，哪怕是一个队列的内容很多，但是每次loop还是会执行一次另外一个队列。