(name, capacity=1)
| 5 | |
| 6 | @coroutine |
| 7 | def create_delivery_man(name, capacity=1): |
| 8 | buffer = [] |
| 9 | while True: |
| 10 | size = 0 |
| 11 | while size < capacity: |
| 12 | pkg_name = yield |
| 13 | if pkg_name: |
| 14 | size += 1 |
| 15 | buffer.append(pkg_name) |
| 16 | print('%s正在接受%s' % (name, pkg_name)) |
| 17 | else: |
| 18 | break |
| 19 | print('=====%s正在派送%d件包裹=====' % (name, len(buffer))) |
| 20 | sleep(3) |
| 21 | buffer.clear() |
| 22 | |
| 23 | |
| 24 | def create_package_center(consumer, max_packages): |