syncthreadcount.java

来自「real-time design patterns in Real-time j」· Java 代码 · 共 25 行

package designPatterns.Rendezvous;

public class SyncThreadCount implements SyncRules {

	SyncThreadCount(long maxThreads) {
		this.maxThreads = maxThreads;
	}
	
	private long thrCount = 0;
	private long maxThreads;
	
	public boolean evaluate() {
		boolean syncPointReached = false;
		if (++thrCount >= maxThreads) {
			syncPointReached = true;
		}
		return syncPointReached;
	}

	public void reset() {
		thrCount = 0;
	}

}