码迷,mamicode.com
首页 > 编程语言 > 详细

Java---17---多线程之间的通信

时间:2015-01-18 21:13:12      阅读:223      评论:0      收藏:0      [点我收藏+]

标签:java   synchronized   thread   同步   多线程   

   在前面我们已经介绍了多线程编程中使用同步机制的重要性,并学会了如何实现同步的方法来正确的访问共享资源。这些线程之间的关系是平等的,批次之间并不存在依赖,他们各自竞争CPU的资源,互不相让,并且还无条件的阻止其他线程对共享资源的访问。然而,也有很多现实问题要求不仅仅要同步的访问同一共享资源,而且线程间还彼此牵制,通过相互通信来向前推进。那么,多个线程之间是如何进行通信的呢?

线程间的通信其实就是多个线程在操作同一个资源,但操作的动作不同。


class Res {
	String name;
	String sex;
}

class Input implements Runnable {
	private Res r;

	public Input(Res r) {
		// TODO Auto-generated constructor stub
		this.r = r;
	}

	public void run() {
		int x = 0;
		while (true) {
			if (x == 0) {
				r.name = "mike";
				r.sex = "man";
			} else {
				r.name = "丽丽";
				r.sex = "女女女";
			}
			x = ++x % 2;
		}
	}
}

class Output implements Runnable {
	private Res r;

	Output(Res r) {
		this.r = r;
	}

	public void run() {
		while (true) {
			System.out.println(r.name + "----" + r.sex);
		}
	}
}

public class Communicate {
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		Res r = new Res();
		Input in = new Input(r);
		Output out = new Output(r);

		Thread t1 = new Thread(in);
		Thread t2 = new Thread(out);

		t1.start();
		t2.start();
	}
}

但是这样写的会出现名字与性别不相匹配的情况。

这就表明了出现了安全问题,当出现安全问题时就要想到需要同步。

那我们加上同步再试一试:

class Res {
	String name;
	String sex;
}

class Input implements Runnable {
	private Res r;
	Object obj = new Object();

	public Input(Res r) {
		// TODO Auto-generated constructor stub
		this.r = r;
	}

	public void run() {
		int x = 0;
		while (true) {
			synchronized (obj) {
				if (x == 0) {
					r.name = "mike";
					r.sex = "man";
				} else {
					r.name = "丽丽";
					r.sex = "女女女";
				}
				x = ++x % 2;
			}
		}
	}
}

class Output implements Runnable {
	private Res r;
	Object obj = new Object();
	Output(Res r) {
		this.r = r;
	}

	public void run() {
		while (true) {
			synchronized (obj)
			{
				System.out.println(r.name + "----" + r.sex);
			}
		}
	}
}

public class Communicate {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		Res r = new Res();
		Input in = new Input(r);
		Output out = new Output(r);

		Thread t1 = new Thread(in);
		Thread t2 = new Thread(out);

		t1.start();
		t2.start();

	}
}

但是这样做之后还是没有解决出现的问题。

那么还是要考虑那两个原则:

1.是否是两个及两个以上的线程?(满足)

2.是否是同一个锁?(??)

 

this 是本类对象就更不用想了。


在内存中已经有了四个.class的对象,用哪一个都是可以的。


class Res {
	String name;
	String sex;
}

class Input implements Runnable {
	private Res r;

	public Input(Res r) {
		// TODO Auto-generated constructor stub
		this.r = r;
	}

	public void run() {
		int x = 0;
		while (true) {
			synchronized (Input.class) {
				if (x == 0) {
					r.name = "mike";
					r.sex = "man";
				} else {
					r.name = "丽丽";
					r.sex = "女女女";
				}
				x = ++x % 2;
			}
		}
	}
}

class Output implements Runnable {
	private Res r;
	Object obj = new Object();

	Output(Res r) {
		this.r = r;
	}

	public void run() {
		while (true) {
			synchronized (Input.class) {
				System.out.println(r.name + "----" + r.sex);
			}
		}
	}
}

public class Communicate {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		Res r = new Res();
		Input in = new Input(r);
		Output out = new Output(r);

		Thread t1 = new Thread(in);
		Thread t2 = new Thread(out);

		t1.start();
		t2.start();

	}
}

但是在本例中,资源r也是独一无二的,也就是说,如果将锁换成是r的话也可以。









Java---17---多线程之间的通信

标签:java   synchronized   thread   同步   多线程   

原文地址:http://blog.csdn.net/u013476556/article/details/42839073

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!