import com.subgraph.orchid.ExitCircuit; //导入依赖的package包/类
List<ExitCircuit> getRandomlyOrderedListOfExitCircuits() {
	final Set<Circuit> notDirectory = getCircuitsByFilter(new CircuitFilter() {
		
		public boolean filter(Circuit circuit) {
			final boolean exitType = circuit instanceof ExitCircuit;
			return exitType && !circuit.isMarkedForClose() && circuit.isConnected();
		}
	});
	final ArrayList<ExitCircuit> ac = new ArrayList<ExitCircuit>();
	for(Circuit c: notDirectory) {
		if(c instanceof ExitCircuit) {
			ac.add((ExitCircuit) c);
		}
	}
	final int sz = ac.size();
	for(int i = 0; i < sz; i++) {
		final ExitCircuit tmp = ac.get(i);
		final int swapIdx = random.nextInt(sz);
		ac.set(i, ac.get(swapIdx));
		ac.set(swapIdx, tmp);
	}
	return ac;
}
 

import com.subgraph.orchid.ExitCircuit; //导入依赖的package包/类
public ExitCircuit openExitCircuitTo(List<Router> path)	throws OpenFailedException {
	final ExitCircuit circuit = CircuitImpl.createExitCircuitTo(this, path);
	if(!tryOpenCircuit(circuit, false, false)) {
		throw new OpenFailedException("Could not create exit circuit for path");
	}
	return circuit;
}
 

import com.subgraph.orchid.ExitCircuit; //导入依赖的package包/类
private void assignPendingStreamsToActiveCircuits() {
	final List<StreamExitRequest> pendingExitStreams = circuitManager.getPendingExitStreams();
	if(pendingExitStreams.isEmpty())
		return;

	for(ExitCircuit c: circuitManager.getRandomlyOrderedListOfExitCircuits()) {
		final Iterator<StreamExitRequest> it = pendingExitStreams.iterator();
		while(it.hasNext()) {
			if(attemptHandleStreamRequest(c, it.next()))
				it.remove();
		}
	}
}
 

import com.subgraph.orchid.ExitCircuit; //导入依赖的package包/类
private boolean attemptHandleStreamRequest(ExitCircuit c, StreamExitRequest request) {
	if(c.canHandleExitTo(request)) {
		if(request.reserveRequest()) {
			launchExitStreamTask(c, request);
		}
		// else request is reserved meaning another circuit is already trying to handle it
		return true;
	}
	return false;
}
 

import com.subgraph.orchid.ExitCircuit; //导入依赖的package包/类
private int countCircuitsSupportingTarget(final ExitTarget target, final boolean needClean) {
	final CircuitFilter filter = new CircuitFilter() {
		public boolean filter(Circuit circuit) {
			if(!(circuit instanceof ExitCircuit)) {
				return false;
			}
			final ExitCircuit ec = (ExitCircuit) circuit;
			final boolean pendingOrConnected = circuit.isPending() || circuit.isConnected();
			final boolean isCleanIfNeeded = !(needClean && !circuit.isClean());
			return pendingOrConnected && isCleanIfNeeded && ec.canHandleExitTo(target);
		}
	};
	return circuitManager.getCircuitsByFilter(filter).size();
}
 

import com.subgraph.orchid.ExitCircuit; //导入依赖的package包/类
private void circuitOpenedHandler(Circuit circuit) {
	if(!(circuit instanceof ExitCircuit)) {
		return;
	}
	final ExitCircuit ec = (ExitCircuit) circuit;
	final List<StreamExitRequest> pendingExitStreams = circuitManager.getPendingExitStreams();
	for(StreamExitRequest req: pendingExitStreams) {
		if(ec.canHandleExitTo(req) && req.reserveRequest()) {
			launchExitStreamTask(ec, req);
		}
	}
}