diplodocus.org Git - flac-archive/blob - jobtest.py

   1 import os
   2 import sys
   3 import jobs
   4
   5 work = range(17)
   6
   7 def getjob():
   8     try:
   9         job = work.pop()
  10     except IndexError:
  11         return None
  12     return lambda: sys.stdout.write('%d %d\n'  % (os.getpid(), job))
  13
  14 jobs.run(get_job=getjob, maxjobs=8,
  15          notify_start=lambda pid, jobs: sys.stdout.write('%d %d jobs\n' % (pid, len(jobs))),
  16          notify_finish=lambda pid, status, jobs: sys.stdout.write('%d %d %d jobs\n' % (pid, status, len(jobs))))