We can use a ThreadPoolTaskExecutor + helper classes to make a nice interface to create the OperationContext and take DB/Coll locks for the callers lambda.

All internal state will need to be protected by the DataReplicator internal mutex, as is done mostly already.