}
ReadEntry entry = (ReadEntry)cache.getOrCreateReadEntry(graph, r, needsToBlock);
if(entry == null) {
- graph.processor.schedule(new SessionTask(graph) {
+ graph.processor.scheduleNow(new SessionTask(graph) {
@Override
public void run0(int thread) {
try {
}
AsyncReadEntry entry = (AsyncReadEntry)cache.getOrCreateAsyncReadEntry(graph, r, needsToBlock);
if(entry == null) {
- graph.processor.schedule(new SessionTask(graph) {
+ graph.processor.scheduleNow(new SessionTask(graph) {
@Override
public void run0(int thread) {
try {