implement multi-threaded producer-consumer xdcr lag collector

Change-Id: Ib45a5fefc4718b73bfc9607c9dfeb390451d043a