Lines Matching defs:Mapper
40 static class Mapper extends Thread {
45 Mapper(FileChannel fc, Semaphore gate) {
67 static Mapper startMapper(FileChannel fc, Semaphore gate) {
68 Mapper r = new Mapper(fc, gate);
77 final Mapper[] mappers;
80 Interruptor(Mapper[] mappers, Semaphore gate) {
87 for (Mapper m : mappers) {
99 Mapper[] mappers = new Mapper[MAPPER_COUNT];
110 mappers[j] = Mapper.startMapper(fc, gate);
130 for (Mapper m: mappers) {
135 System.err.println("Mapper thread failed with: " + e);
138 System.err.println("Mapper thread did not terminate:");