java模拟线程干扰

package async;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;

public class Main {
	
	static final int threadInitNumber = 2;
	
	public static void main(String[] args){
		
		Counter counter = new Counter();
		
		List<Thread> threads = new ArrayList<Thread>(); 
		
		for(int i=0;i<threadInitNumber;i++){
			threads.add(new Thread(new Async(counter),"thread" + i));
		}
		
		for(Thread thread : threads){
			thread.start();
		}
	}

}

/*
 * 线程干扰：多个线程访问共享对象的非原子性操作时，会线程竞争，从而产生线程干扰
 * 
 * 模拟线程干扰
 */
class Async implements Runnable{
	
	private Counter counter = new Counter();
	
	public Async() {
		
	}
	public Async(Counter counter) {
		super();
		this.counter = counter;
	}
	
	@Override
	public void run() {
		
		Random random = new Random();
		while(true){
			if(random.nextInt(10)<5){
				print("execute increment:" + counter.current());
				counter.increment();
			}else{
				if(counter.current()>0){
					print("execute decrement:" + counter.current());
					counter.decrement();	
				}
			}
			print("counter current value:" + counter.current());
			if(random.nextInt(100)==1){
				print("exit thread......................");
				return;
			}
		}
	}
	
	void print(String content){
		
		System.out.println(Thread.currentThread().getName() + " ---> " + content);
	}
	
}

class Counter {
	
	private int count = 0;
	
	public int current(){
		return count;
	}
	
	public int increment(){
		return count++;
	}
	
	public int decrement(){
		return count--;
	}
}