共有リソースへの不正アクセス
2337 ワード
次のコードを見てください.このコードはテンプレート設計モードを採用しています.
//偶数生成クラスの作成
テストクラスを作成し、10スレッドを起動し、リソースに正しくアクセスしているかどうかを確認します.
//テストの結果、奇数が多く印刷されました.リソースへのアクセスエラーの原因は、next()メソッド自体が原子メソッドではなく、1つのスレッドで1番目の++操作を行った後、2番目のスレッドが値を取った可能性があります.
public abstract class IntGenerator {
private volatile boolean canceled=false;
public abstract int next();
public void cancel()
{ this.canceled=false;
}
public boolean isCanceled()
{
return this.canceled;
}
}
======================== //偶数生成クラスの作成
public class EvenGenerator extends IntGenerator{
private int currentEvenValue=0;
@Override
public int next() {
// TODO Auto-generated method stub
++currentEvenValue;
++currentEvenValue;
return currentEvenValue;
}
public static void main(String[] args)
{
EvenChecker.test(new EvenGenerator());
}
}
=========================== テストクラスを作成し、10スレッドを起動し、リソースに正しくアクセスしているかどうかを確認します.
public class EvenChecker implements Runnable{
private IntGenerator generator;
private final int id;
public EvenChecker(IntGenerator generator,int id) {
// TODO Auto-generated constructor stub
this.generator=generator;
this.id=id;
}
@Override
public void run() {
// TODO Auto-generated method stub
while(!generator.isCanceled())
{
int val=generator.next();
if(val%2!=0)
{
System.out.println(val+ " is not even!");
generator.cancel();//
}
else
{
//System.out.println(val+" is even!");
}
}
}
public static void test(IntGenerator gp,int count)
{
System.out.println("Press Ctrl+C to Exit");
ExecutorService exec=Executors.newCachedThreadPool();
for(int i=0;i<count;i++)
exec.execute(new EvenChecker(gp,i));
}
public static void test(IntGenerator gp)
{
test(gp,10);
}
}
//テストの結果、奇数が多く印刷されました.リソースへのアクセスエラーの原因は、next()メソッド自体が原子メソッドではなく、1つのスレッドで1番目の++操作を行った後、2番目のスレッドが値を取った可能性があります.