public void execute(RequestProcessor processor) throws DatabaseException {
AsyncMultiRead<Object> request = new AsyncMultiRead<Object>() {
-
- @Override
- public int threadHash() {
- return hashCode();
- }
@Override
public void perform(AsyncReadGraph graph,
};
if(processor instanceof WriteGraph) processor.syncRequest(request, procedure);
- else processor.asyncRequest(request, procedure);
+ else processor.syncRequest(request, procedure);
}