initialize before worker threads connect and start queue in blocking mode.