Implemented worker/flusher more properly

http://swimmingpython.net/blog/?p=599