def worker(srcdir, topdir):
        have_job = True
        while have_job:
            try:
                item = q.get_nowait()
            except:
                print("Thread has no job left, terminating.")
                have_job = False
                return
            try:
                raise Exception("die you stupid thing")
                item(srcdir, topdir)
            except:
                sys.exit(1)
            finally:
                q.task_done()

    for i in range(4):
         t = Thread(target=worker, args=(srcdir, topdir))
         t.daemon = True
         t.start()

    q.join()
    print( "Asset fetch finished, took %s" % (datetime.now() - start_time,) )