マルチスレッドによる偶数インスタンスの生成

次の手順を見てください.
 

/**
 *  
 */
public abstract class IntGenerator {

	private boolean cancel = false;

	public abstract int next();

	public void cancel() {
		this.cancel = true;
	}

	public boolean isCancel() {
		return this.cancel;
	}

}

 

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 *  
 *
 */
public class EvenChecker implements Runnable {

	private IntGenerator intGenerator;
	private final int id ;
	
	public EvenChecker(IntGenerator intGenerator,int ident) {
		this.intGenerator = intGenerator;
		this.id = ident;
	}
	
	@Override
	public void run() {
		while(!intGenerator.isCancel()) {
			int val = intGenerator.next();
			if (val % 2 != 0) {
				System.out.println(val + " not even");
				intGenerator.cancel();
			}
		}
	}

	public static void test(IntGenerator gp,int count) {
		ExecutorService exec = Executors.newCachedThreadPool();
		for (int i = 0; i < count; i++) {
			exec.execute(new EvenChecker(gp,i));
		}
		exec.shutdown();
	}
	
	public static void test(IntGenerator gp) {
		test(gp,10);
	}
}

 

/**
 *  
 *
 */
public class EvenGenerator extends IntGenerator {

	/**
	 * currentEvenValue  ， 
	 * 
	 */
	private int currentEvenValue = 0;

	/**
	 *  ， 
	 */
	@Override
	public int next() {
		/**  ：  ++ ，
		 	 return ， next 
		*/
		++currentEvenValue;
		++currentEvenValue;
		return currentEvenValue;
	}

	public static void main(String[] args) {
		EvenChecker.test(new EvenGenerator());
	}
}

多くの場合、偶数ではない結果を実行することができます.私の機械では、偶数ではない結果を実行することが多く、結果を出力できないことがあります.
この問題を解決する方法は以下の通りです.

@Override
public synchronized int next() {
	/**  ：  ++ ，
	 	 return ， next 
	*/
	++currentEvenValue;
	++currentEvenValue;
	return currentEvenValue;
}

next()にキーワードsynchronizedを付けると、next()メソッドが同期メソッドであり、いつでも1つのスレッドのみがnext()メソッドボディを許可できることを示します.