import java.util.concurrent.atomic.AtomicInteger;
import org.simantics.db.service.ServiceActivityMonitor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import gnu.trove.map.TObjectIntMap;
import gnu.trove.map.hash.TObjectIntHashMap;
public class ServiceActivityMonitorImpl implements ServiceActivityMonitor {
+ private static final Logger LOGGER = LoggerFactory.getLogger(ServiceActivityMonitorImpl.class);
+
public static final long REPORTING_PERIOD = 5L;
Semaphore sem = new Semaphore(1);
if(waitForCompletion(REPORTING_PERIOD, TimeUnit.SECONDS))
return;
synchronized (ids) {
- System.err.println("ServiceActivityMonitorImpl.waitForCompletion: " + ids);
- }
+ LOGGER.info("waitForCompletion: " + ids);
+ }
}
}