下面用生产者和消费者问题来展示协程如何解决软件架构中“谁拥有主循环”的问题。在一种设计中，程序通过调用消费者启动。当消费者需要新值时就唤醒生产者，生产者向消费者返回新值后挂起，直到消费者再次将其唤醒。因此，我们将这种设计称为消费者驱动( consumer-driven)式的设计。

       同时，我们可以使用过滤器来扩展上述设计。过滤器位于生产者和消费者之间，用于完成一些对数据进行某种变换的任务。过滤器(filter) 既是一个消费者又是一一个生产者，它通过唤醒一个生产者来获得新值，然后又将变换后的值传递给消费者。

       代码的逻辑可以参照下文来理解：根据“consumer(filter(producer())”，先调用producer()函数，生成一个待启动的协程，这个协程包含的代码段功能是从io流中读取一个值（local x = io.read()），然后调用send ()函数，其功能是挂起正在进行的这个协程。然后从filter(producer())这个命令，函数filter（）接收到调用producer()返回的协程，然后函数filter（）调用receive ()函数得到producer()函数生成的新数，并和行数一块打印出来（x = string.format("%5d %s"， line, x)）。最后调用consumer（）函数，将函数filter（）挂起的协程作为参数，然后重启这个协程，得到producer()函数生成的数，写入io流中。

代码如下：

function receive (prod)
  local status, value = coroutine .resume (prod)
  return value
end

function send (x)
  coroutine . yield(x)

function producer ()
  return coroutine.create(function ()
    while true do
     local x = io.read()     --产生新值
    send(x)
   end
 end)
end

function filter (prod)
  return coroutine . create(function ()
    for line = 1, math.huge do
     local x = receive(prod) -- 接收新值
     x = string.format("%5d %s"， line, x)
     send(x)  --发送给消费者
    end
   end)
end

function consumer (prod)
  while true do
    local x = receive(prod)   --获取新值
      io.write(x，"\n")     --消费新值
    end
end
consumer(filter(producer())