java多线程同步问题

0 0

java多线程同步问题5

public class Number implements Runnable{
	
	private Integer count=1;

	@Override
	public void run() {
		while(true){
			synchronized (count) {
				if(count>30){
					break;
				}
				try {
					Thread.sleep(200);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				System.out.println(count+"-----------");
				count++;
				System.out.println(count);
			}
		}
	}
	
	public static void main(String[] args) {
		Number n = new Number();
		
		Thread t1=  new Thread(n,"Number1");
		Thread t2=  new Thread(n,"Number2");
		Thread t3=  new Thread(n,"Number3");
		
		t1.start();
		t2.start();
		t3.start();
	}
	
}

这段线程可能会打印如下：
1-----------
2
2-----------
3
3-----------
4
4-----------
4-----------
4-----------
6
5
7
7-----------
8
8-----------
9
9-----------
10
10-----------
10-----------
11
12
12-----------
13
13-----------
14
13-----------
15
15-----------
16
16-----------
17
17-----------
18
18-----------
19
19-----------
20
20-----------
21
21-----------
22
22-----------
23
23-----------
24
24-----------
25
25-----------
26
26-----------
27
27-----------
28
28-----------
29
29-----------
30
30-----------
31
31-----------
32
31-----------
33

感觉好像没有同步，有几个打印的是一样，比如4---------

如果把synchronized (count) 改为synchronized (this) 就是可以的

这个不清楚为什么，有能解释的吗？

java 多线程同步

2014年7月08日 10:45

xz1367
26
0 0 3

6个答案按时间排序按投票排序

0 0

采纳的答案

因为count++;后，count不再是一开始的对象，因此某些时间，不同的线程hold了不同的count。

2014年7月08日 12:15

gates_lee
40
0 0 3

2条评论

0 0

我一直都是这么写的，感觉应该没是错误.

public class Number extends Thread {
	
	private static int i = 0;
	
	public synchronized int get(){
		return i++;
	}
	
	public void run(){
		while(true){
			int a = get();
			if(a>30){
				break;
			}
			System.out.println(Thread.currentThread().getName()+":"+a);
		}
	}
	
	public static void main(String[] args) {
		for (int i = 0; i < 3; i++) {
			new Thread(new Number()).start();
		}
	}
	
}

2014年7月09日 16:13

ahack
70
0 1 8

添加评论

0 0

	
	private byte[] lock = new byte[0];

	private  Integer count = 1;

	@Override
	public void run() {
		while (true) {
			if (count > 30) {
				break;
			}
			try {
				Thread.sleep(200);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			synchronized (lock) {
				System.out.println(count + "-----------");
				count = count + 1;
				System.out.println(count);

			}
		}
	}

一般这样写，锁对象要小，锁内容只和变量控制相关

2014年7月09日 13:39

whzhaha
40
0 0 2

添加评论

0 0

的确是count的原因。
当第一个线程进入run领域时，在局部作用域会出现一个局部的count引用指向count对象，此时全世界有两个引用指向count，一个是顶端的count，一个是局部的。然后第一个线程执行完count++后，产生一个新的count对象，并且将顶端的引用切换到了这个新的未被锁定的对象，于是第二个线程就鱼贯而入。此时就出现了两个线程在run中，最终造成了混乱。

2014年7月09日 01:11

white_crucifix
131
1 1 27

添加评论

0 0

在java里，只有常量才能 ++ ，如：int i = 0 ; i++;
那为什么 Integer 的对象也可以 ++ 呢？
这其实是编译器帮你干的事情.
Integer i = 0 ;
i ++;

相当于
int _i = 0;
Integer i = new Integer(_i);
i = new Integer (_i++);

然后你应该知道为什么你得同步失败了吧?

2014年7月08日 19:00

yhb0324dyx
30
0 0 0