RenJuan/TASKPM
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Report some statistics and execution times for snapshot creation

Browse source 
FEA: ItEr60S04ValidacionEProbasFuncionaisItEr59S04
This commit is contained in:
Óscar González Fernández 2010-09-12 17:21:00 +02:00
parent 44fde9421b
commit a7bc4d43eb
4 changed files with 102 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
navalplanner-business/src/main/java/org/navalplanner/business/hibernate/notification/HibernateDatabaseModificationsListener.java
View file

@ -106,9 +106,10 @@ public class HibernateDatabaseModificationsListener implements
}
@Override
public <T> IAutoUpdatedSnapshot<T> takeSnapshot(Callable<T> callable, ReloadOn reloadOn) {
public <T> IAutoUpdatedSnapshot<T> takeSnapshot(String name,
Callable<T> callable, ReloadOn reloadOn) {
final NotBlockingAutoUpdatedSnapshot<T> result;
result = new NotBlockingAutoUpdatedSnapshot<T>(callable);
result = new NotBlockingAutoUpdatedSnapshot<T>(name, callable);
for (Class<?> each : reloadOn.getClassesOnWhichToReload()) {
interested.putIfAbsent(each, emptyQueue());
BlockingQueue<NotBlockingAutoUpdatedSnapshot<?>> queue = interested

2
navalplanner-business/src/main/java/org/navalplanner/business/hibernate/notification/ISnapshotRefresherService.java
View file

@ -27,6 +27,6 @@ import java.util.concurrent.Callable;
*/
public interface ISnapshotRefresherService {
public <T> IAutoUpdatedSnapshot<T> takeSnapshot(Callable<T> callable, ReloadOn reloadOn);
public <T> IAutoUpdatedSnapshot<T> takeSnapshot(String name, Callable<T> callable, ReloadOn reloadOn);
}

82
navalplanner-business/src/main/java/org/navalplanner/business/hibernate/notification/NotBlockingAutoUpdatedSnapshot.java
View file

@ -41,6 +41,10 @@ class NotBlockingAutoUpdatedSnapshot<T> implements IAutoUpdatedSnapshot<T> {
private final AtomicReference<State> currentState;
private final String name;
private final ExecutionsReport executionsReport;
private abstract class State {
abstract T getValue();
@ -156,10 +160,13 @@ class NotBlockingAutoUpdatedSnapshot<T> implements IAutoUpdatedSnapshot<T> {
}
public NotBlockingAutoUpdatedSnapshot(Callable<T> callable) {
public NotBlockingAutoUpdatedSnapshot(String name, Callable<T> callable) {
Validate.notNull(callable);
Validate.notNull(name);
this.name = "*" + name + "*";
this.callable = callable;
currentState = new AtomicReference<State>(new NotLaunchState());
this.currentState = new AtomicReference<State>(new NotLaunchState());
this.executionsReport = new ExecutionsReport();
}
@Override
@ -168,7 +175,8 @@ class NotBlockingAutoUpdatedSnapshot<T> implements IAutoUpdatedSnapshot<T> {
}
public void reloadNeeded(ExecutorService executorService) {
Future<T> future = executorService.submit(callable);
Future<T> future = executorService
.submit(callableDecoratedWithStatistics());
State previousState;
State newState = null;
do {
@ -185,7 +193,8 @@ class NotBlockingAutoUpdatedSnapshot<T> implements IAutoUpdatedSnapshot<T> {
if (hasBeenInitialized()) {
return;
}
Future<T> future = executorService.submit(callable);
Future<T> future = executorService
.submit(callableDecoratedWithStatistics());
State previous = currentState.get();
State newState = previous.nextState(future);
boolean compareAndSet = currentState.compareAndSet(previous, newState);
@ -198,4 +207,69 @@ class NotBlockingAutoUpdatedSnapshot<T> implements IAutoUpdatedSnapshot<T> {
return currentState.get().hasBeenInitialized();
}
private Callable<T> callableDecoratedWithStatistics() {
final long requestTime = System.currentTimeMillis();
return new Callable<T>() {
@Override
public T call() throws Exception {
long start = System.currentTimeMillis();
long timeWaiting = start - requestTime;
try {
return callable.call();
} finally {
long timeExecuting = System.currentTimeMillis() - start;
executionsReport.newData(timeWaiting, timeExecuting);
}
}
};
}
private static class Data {
final int executionTimes;
long totalMsWaiting;
long totalMsExecuting;
private Data(int executionTimes, long totalMsWaiting,
long totalMsExecuting) {
this.executionTimes = executionTimes;
this.totalMsWaiting = totalMsWaiting;
this.totalMsExecuting = totalMsExecuting;
}
public Data newData(long timeWaiting, long timeExcuting) {
return new Data(executionTimes + 1, totalMsWaiting + timeWaiting,
totalMsExecuting + timeExcuting);
}
}
private class ExecutionsReport {
private AtomicReference<Data> data = new AtomicReference<Data>(
new Data(0, 0, 0));
public void newData(long timeWaiting, long timeExecuting) {
Data previousData;
Data newData;
do {
previousData = data.get();
newData = previousData.newData(timeWaiting, timeExecuting);
} while (!data.compareAndSet(previousData, newData));
report(timeWaiting, timeExecuting, newData);
}
private void report(long timeWaiting, long timeExecuting, Data data) {
LOG.info(name + " took " + timeExecuting + " ms executing");
LOG.info(name + " waited for " + timeWaiting
+ " ms until executing");
LOG.info(name + " mean time waiting for execution: "
+ data.totalMsWaiting / data.executionTimes + " ms");
LOG.info(name + " mean time executing: "
+ data.totalMsExecuting / data.executionTimes + " ms");
LOG.info(name + " has been executed " + data.executionTimes
+ " times");
}
}
}

33
navalplanner-business/src/main/java/org/navalplanner/business/hibernate/notification/PredefinedDatabaseSnapshots.java
View file

@ -125,25 +125,32 @@ public class PredefinedDatabaseSnapshots {
@PostConstruct
@SuppressWarnings("unused")
private void postConstruct() {
criterionsMap = snapshot(calculateCriterionsMap(), CriterionType.class,
Criterion.class);
labelsMap = snapshot(calculateLabelsMap(), LabelType.class, Label.class);
listWorkers = snapshot(calculateWorkers(), Worker.class);
listCostCategories = snapshot(calculateListCostCategories(),
criterionsMap = snapshot("criterions map", calculateCriterionsMap(),
CriterionType.class, Criterion.class);
labelsMap = snapshot("labels map", calculateLabelsMap(),
LabelType.class, Label.class);
listWorkers = snapshot("workers", calculateWorkers(), Worker.class);
listCostCategories = snapshot("list cost categories",
calculateListCostCategories(),
CostCategory.class);
listCriterion = snapshot(calculateListCriterion(), Criterion.class);
mapResources = snapshot(calculateMapResources(), Resource.class,
Worker.class, Machine.class, VirtualWorker.class);
externalCompanies = snapshot(calculateExternalCompanies(),
listCriterion = snapshot("list criterions", calculateListCriterion(),
Criterion.class);
mapResources = snapshot("map resources", calculateMapResources(),
Resource.class, Worker.class, Machine.class,
VirtualWorker.class);
externalCompanies = snapshot("external companies",
calculateExternalCompanies(),
ExternalCompany.class);
customerReferences = snapshot(calculateCustomerReferences(),
customerReferences = snapshot("customer references",
calculateCustomerReferences(), Order.class);
ordersCodes = snapshot("order codes", calculateOrdersCodes(),
Order.class);
ordersCodes = snapshot(calculateOrdersCodes(), Order.class);
}
private <T> IAutoUpdatedSnapshot<T> snapshot(Callable<T> callable,
private <T> IAutoUpdatedSnapshot<T> snapshot(String name,
Callable<T> callable,
Class<?>... reloadOnChangesOf) {
return snapshotRefresherService.takeSnapshot(
return snapshotRefresherService.takeSnapshot(name,
callableOnReadOnlyTransaction(callable),
ReloadOn.onChangeOf(reloadOnChangesOf));
}