boolean gotMutex = impl.tryAcquireMutex();
boolean done = false;
+ // TODO: fix this properly pleease
+ int count = 0;
while (!done) {
if (gotMutex || borrowMutex) {
runWithMutex();
done = true;
} else {
- LOGGER.warn("Retry mutex acquire");
+ if (count % 100 == 0)
+ LOGGER.warn("Retry mutex acquire");
gotMutex = impl.tryAcquireMutex();
+ count++;
}
}