Class EJob

src/com/winvector/util/ThreadedReducer.java:28–52

	}
	
	private final class EJob implements Runnable {
		public final Z baseRes;
		private final Iterable<? extends T> sourcei;
		
		public EJob(final Z baseRes,
				final Iterable<? extends T> sourcei) {
			this.baseRes = baseRes;
			this.sourcei = sourcei;
		}

		@Override
		public void run() {
			final Z r;
			synchronized (baseRes) {
				r = baseRes.newObserver();
			}
			for(final T di: sourcei) {
				r.observe(di);
			}
			synchronized (baseRes) {
				baseRes.observe(r);
			}
		}
		
	}

	
	/**