java线程控制安全

synchronized()


在线程运行的时候,有时会出现线程安全问题
例如:买票程序,有可能会出现不同窗口买同一张编号的票

运行如下代码:

public class runable implements Runnable {
	//此处定义变量是一个对象的变量,run()函数调用的时候不同的线程调用
	int i=1;
	@Override
	public void run() {
		while(true){
			//输出当前线程名字和票数
			System.out.println(Thread.currentThread().getName()+i);
			i++;
			//当前线程放弃CPU,重新竞争资源
			Thread.yield();
			if(i>100)break;
		}
	}
}

  

public class main {

	public static void main(String[] args) throws InterruptedException {
		//实现接口
		runable ra=new runable();
		//生成Thread对象,并将接口对象作为参数
		Thread t1=new Thread(ra);
		Thread t2=new Thread(ra);
		//给两个线程设置名字
		t1.setName("线程一");
		t2.setName("线程二");
		//开始线程
		t1.start();
		t2.start();
	}
}

  会出现如下情况:

java线程控制安全

 

 

处理方法:加入线程锁

public class runable implements Runnable {
	//此处定义变量是一个对象的变量,run()函数调用的时候不同的线程调用
	int i=1;
	@Override
	public void run() {
		//加入进程锁,锁住的是this这个对象,在this这个对象释放CPU之前,所有的含有进程锁的代码都不能运行
		synchronized (this) {
			while(true){
				//输出当前线程名字和票数
				System.out.println(Thread.currentThread().getName()+i);
				i++;
				//当前线程放弃CPU,重新竞争资源
				Thread.yield();
				if(i>100)break;
			}
		}
		
	}
}

  

上一篇:java单例模式


下一篇:java抽象类和抽象方法之间的关系