线程同步synchronized和volatile

上篇经过一个简单的例子说明了线程安全与不安全,在例子中不安全的状况下输出的结果刚好是逐个递增的,为何会产生这样的结果呢,由于创建的Count对象是线程共享的,一个线程改变了其成员变量num值,下一个线程正巧读到了修改后的num,因此会递增输出。java

要说明线程同步问题首先要说明Java线程的两个特性,可见性和有序性。多个线程之间是不能直接传递数据交互的,它们之间的交互只能经过共享变量来实现。拿上篇博文中的例子来讲明,在多个线程之间共享了Count类的一个对象,这个对象是被建立在主内存(堆内存)中,每一个线程都有本身的工做内存(线程栈),工做内存存储了主内存Count对象的一个副本,当线程操做Count对象时,首先从主内存复制Count对象到工做内存中,而后执行代码count.count(),改变了num值,最后用工做内存Count刷新主内存Count。当一个对象在多个内存中都存在副本时,若是一个内存修改了共享变量,其它线程也应该可以看到被修改后的值,此为可见性。由上述可知,一个运算赋值操做并非一个原子性操做,多个线程执行时,CPU对线程的调度是随机的,咱们不知道当前程序被执行到哪步就切换到了下一个线程,一个最经典的例子就是银行汇款问题,一个银行帐户存款100,这时一我的从该帐户取10元,同时另外一我的向该帐户汇10元,那么余额应该仍是100。那么此时可能发生这种状况,A线程负责取款,B线程负责汇款,A从出内存读到100B从主内存读到100A执行减10操做,并将数据刷新到主内存,这时主内存数据100-10=90,而B内存执行加10操做,并将数据刷新到主内存,最后主内存数据100+10=110,显然这是一个严重的问题,咱们要保证A线程和B线程有序执行,先取款后汇款或者先汇款后取款,此为有序性
安全

看代码,TranditionalThead.java建立两个线程去访问同一个方法多线程

package org.thread;

public class TranditionalThead {

	
	public static void main(String[] args) {
		final Outputer outputer = new Outputer();
		Runnable runnable1 = new Runnable(){
			public void run(){
				outputer.input("HeinrichChen");
			};
			
		};
		
		Runnable runnable2 = new Runnable(){
			
			public void run(){
				outputer.input("Heinrich.Shen");
			}
		};
		
		
		new Thread(runnable1).start();
		new Thread(runnable2).start();
	}
	
	 
}
package org.thread;

public class Outputer {
	
	public void input(String name){
		
			for(int i =0;i<name.length();i++){
				System.out.print(name.charAt(i));
			}
		
	}

}

运行的结果:并发

 

  HHeinrich.eSheninrichChen
  我想要的结果是
  HeinrichChenHeinrich.Shen


  这个时候他们会出现咱们不想要出现的事情   这就是线程同步问题,咱们但愿output方法被一个线程完整的执行完以后在切换到下一个线程,   Java中使用synchronized保证一段代码在多线程执行时是互斥的,有两种用法:ide

第一种this

synchronized (this) {
			for(int i =0;i<name.length();i++){
				System.out.print(name.charAt(i));
			}
		}

锁住咱们须要操做的代码块spa

使用synchronized将须要互斥的代码包含起来,并上一把锁。
线程

运行的结果是code

  HeinrichChenHeinrich.Shen

这就是我想要的结果对象

第二种

synchronized加在须要互斥的方法上。

也便是

HeinrichChenHeinrich.Shen

这种方式就至关于用this锁住整个方法内的代码块,若是用synchronized加在静态方法上,就至关于用××××.class锁住整个方法内的代码块。使用synchronized在某些状况下会形成死锁,死锁问题之后会说明。



每一个锁对象都有两个队列,一个是就绪队列,一个是阻塞队列,就绪队列存储了将要得到锁的线程,阻塞队列存储了被阻塞的线程,当一个线程被唤醒(notify)后,才会进入到就绪队列,等待CPU的调度,反之,当一个线程被wait后,就会进入阻塞队列,等待下一次被唤醒,这个涉及到线程间的通讯,下一篇博文会说明。看咱们的例子,当第一个线程执行输出方法时,得到同步锁,执行输出方法,刚好此时第二个线程也要执行输出方法,但发现同步锁没有被释放,第二个线程就会进入就绪队列,等待锁被释放。一个线程执行互斥代码过程以下:

1. 得到同步锁;

2. 清空工做内存;

3. 从主内存拷贝对象副本到工做内存;

4. 执行代码(计算或者输出等)

5. 刷新主内存数据;

6. 释放同步锁。

因此,synchronized既保证了多线程的并发有序性,又保证了多线程的内存可见性。

volatile是第二种Java多线程同步的手段,根据JLS的说法,一个变量能够被volatile修饰,

在这种状况下内存模型确保全部线程能够看到一致的变量值,来看一段代码:

package org.thread;

public class CountNum {

	public static int i = 0, j = 0;

	public static void count() {

		for (int m = 0; m < 10000; m++) {

			j++;

			i++;
		}

	}

	public static void show() {
		if (i < j) {
			System.out.println("i==>" + i + "==="
					+ Thread.currentThread().getName());
			System.out.println("j==>" + j + "==="
					+ Thread.currentThread().getName());
		}
	}
}

一些线程执行one方法,另外一些线程执行count方法,show方法有可能打印出j比i大的值,按照以前分析的线程执行过程分析一下:

1. 将变量i从主内存拷贝到工做内存;

2. 改变i的值;

3. 刷新主内存数据;

4. 将变量j从主内存拷贝到工做内存;

5. 改变j的值;

6. 刷新主内存数据;

这个时候执行show方法的线程先读取了主存i原来的值又读取了j改变后的值,这就致使了程序的输出不是咱们预期的结果,那么能够在共享变量以前加上volatile

package org.thread;

public class CountNum {

	public volatile static int i = 0, j = 0;

	public static void count() {

		for (int m = 0; m < 10000; m++) {

			j++;

			i++;
		}

	}

	public static void show() {
		if (i < j) {
			System.out.println("i==>" + i + "==="
					+ Thread.currentThread().getName());
			System.out.println("j==>" + j + "==="
					+ Thread.currentThread().getName());
		}
	}
}
package org.thread;

public class CountTest {
	
	public static void main(String[] args) {
		
		
		Runnable runnable1 = new Runnable() {
			
			@Override
			public void run() {
				
				new CountNum().count();
			}
		};
		
		Runnable runnable2 = new Runnable() {
			
			@Override
			public void run() {
				new CountNum().show();
			}
		};
		
		
		for(int i=0;i<1000;i++){
			new Thread(runnable1).start();
			new Thread(runnable2).start();
		}
		
	}
	

}
i==>4938===Thread-3
j==>7160===Thread-3
i==>7951===Thread-7
j==>8328===Thread-7
i==>8814===Thread-11
j==>9169===Thread-11
i==>18925===Thread-15

加上volatile能够将共享变量ij的改变直接响应到主内存中,这样保证了ij的值能够保持一致,然而咱们不能保证执行two方法的线程是在ij执行到什么程度获取到的,因此volatile能够保证内存可见性,不能保证并发有序性。

相关文章
相关标签/搜索