code: def register(coordinator):
      
      fetch_queue = Queue.Queue()
      coordinator.register(FetchItem, fetch_queue)
      for i in xrange(FLAGS.fetch_threads):
          coordinator.worker_threads.append(
              FetchThread(fetch_queue, coordinator.input_queue))
docs: Registers this module as a worker with the given coordinator.