生產(chǎn)者消費(fèi)者：

import logging
import time

logging.basicConfig(level = logging.DEBUG)
log = logging.getLogger(__file__)


def consumer():
    log.info("consumer start")
    while True:
        flag = yield
        log.info("running now: %s" %flag)
        time.sleep(1)

def producer(model):
    model.send(None) # 啟動(dòng)協(xié)程
    for i in range(10):
        log.info("producer running...")
        model.send(i)

if __name__ == "__main__":
    aa = consumer()
    producer(aa)

動(dòng)態(tài)延時(shí)計(jì)算 斐波那契數(shù)列

import time
import random

def fib(n, start):
    index = 0
    a = 0
    b = 1
    start = start
    while index < n:
        sleep_cnt = yield start
        print("let me think {} seconds".format(sleep_cnt))
        time.sleep(sleep_cnt)
        a, b = b, a + b
        index += 1
        start -= 1

print("test yield send")
N = 20

sfib = fib(N, 11)
res = next(sfib)

while True:
    print(res)
    try:
        res = sfib.send(random.uniform(0, 0.5) * 10)
    except StopIteration:
        break