(db)
| 319 | |
| 320 | # caution: modifies the database! |
| 321 | def queue_single_client_example(db): |
| 322 | queue = Queue(Subspace(('queue_example',)), False) |
| 323 | queue.clear(db) |
| 324 | |
| 325 | for i in range(10): |
| 326 | queue.push(db, i) |
| 327 | |
| 328 | for i in range(10): |
| 329 | print queue.pop(db) |
| 330 | |
| 331 | |
| 332 | def push_thread(queue, db, id, num): |