I'm not sure about that, e.g. restartBrokenTransfers would have to acquire both locks because it changes `taskQueue` as well as `transfersBySource`/`transfersBySegment`. I did change `StateConsumerImpl.this` to `this`, though, it was one of the reasons I extracted the method :)