bg_worker.py

#! /usr/bin/python
# -*- coding: utf-8 -*-
# cody by linker.lin@me.com

__author__ = 'linkerlin'

import threading
import Queue
import time


class BGWorker(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)
        self.q = Queue.Queue()

    def post(self, job):
        self.q.put(job)

    def run(self):
        while 1:
            job = None
            try:
                job = self.q.get(block=True)
                if job:
                    job()
            except Exception as ex:
                print "Error,job exception:", ex.message, type(ex)
                time.sleep(0.005)
            else:
                #print "job: ", job, " done"
                print ".",
                pass
            finally:
                time.sleep(0.005)


bgworker = BGWorker()
bgworker.setDaemon(True)
bgworker.start()