GlobalQuery firstquery = global new GlobalQuery(firstmachine, firstpage);
Queue todoList = global new Queue();
GlobalQuery firstquery = global new GlobalQuery(firstmachine, firstpage);
Queue todoList = global new Queue();
DistributedHashMap results = global new DistributedHashMap(100, 100, 0.75f);
todoList.push(firstquery);
for (i = 0; i < NUM_THREADS; i++) {
DistributedHashMap results = global new DistributedHashMap(100, 100, 0.75f);
todoList.push(firstquery);
for (i = 0; i < NUM_THREADS; i++) {
- qt[i] = global new QueryTask(todoList, doneList, maxDepth, results);
+ qt[i] = global new QueryTask(todoList, visitedList, maxDepth, results);
works[i] = global new Work(qt[i], NUM_THREADS, i, currentWorkList);
}
}
works[i] = global new Work(qt[i], NUM_THREADS, i, currentWorkList);
}
}