| 123456789101112131415161718192021222324 |
- #!/usr/bin/env python3
- import os
- from multiprocessing import Pool
- import redis
- from rq import Worker, Queue, Connection
- listen = ['default']
- redis_url = 'redis://localhost:6379'
- conn = redis.from_url(redis_url)
- q = Queue('default', connection=conn)
- def do_work(elem):
- with Connection(conn) as c:
- print("working")
- worker = Worker([q])
- worker.work()
- print("finished")
- if __name__ == '__main__':
- p = Pool(2)
- p.map(do_work, [1,2])
|
