您当前的位置: 首页 > 研发管理

守旧线程互斥技术

发布时间：2011-06-18 11:56:24 文章来源：www.iduyao.cn 采编人员：星星草

传统线程互斥技术

2个线程在同一个实例的方法中输出

会出现如下结果：

zhangxiaoxiang
zhangxiaoxiang
lihuoming
zhangxiaoxiang
lihuomizhangxiaoxiang
ng
zhangxiaoxiang
lihuoming
zhangxiaoxiang

如下代码可以产生错误的结果：

1、2个线程同时访问，output方法一个线程没有允许完成另一个线程就进来。

package cn.itcast.heima2;

public class TraditionalTreadSynchrorized {

	public static void main(String[] args) {
		new TraditionalTreadSynchrorized().init();
	}

	public void init() {
		final Outputer output = new Outputer();
		new Thread(new Runnable() {
			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output("zhangxiaoxiang");
				}
			}
		}).start();

		new Thread(new Runnable() {

			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output("lihuoming");
				}
			}
		}).start();
	}

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

	}
}

正确代码：

使用对象锁机制将输出体进行锁定

synchronized (this) { }

package cn.itcast.heima2;

public class TraditionalTreadSynchrorized {

	public static void main(String[] args) {
		new TraditionalTreadSynchrorized().init();
	}

	public void init() {
		final Outputer output = new Outputer();
		new Thread(new Runnable() {
			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output("zhangxiaoxiang");
				}
			}
		}).start();

		new Thread(new Runnable() {

			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output("lihuoming");
				}
			}
		}).start();
	}

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

	}
}

2、错误代码

虽然两个线程调用的方法不同，可是还是在同一个对象中，当一个线程没有输出完毕的时候第二个线程就打印了

system.out.println();进行换行。

package cn.itcast.heima2;

public class TraditionalTreadSynchrorized {

	public static void main(String[] args) {
		new TraditionalTreadSynchrorized().init();
	}

	public void init() {
		final Outputer output = new Outputer();
		new Thread(new Runnable() {
			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output("zhangxiaoxiang");
				}
			}
		}).start();

		new Thread(new Runnable() {

			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output2("lihuoming");
				}
			}
		}).start();
	}

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

	}
}

正确代码：

synchronized 关键字加在方法上默认锁定this 对象如果在方法中需要使用synchronized(this){}

package cn.itcast.heima2;

public class TraditionalTreadSynchrorized {

	public static void main(String[] args) {
		new TraditionalTreadSynchrorized().init();
	}

	public void init() {
		final Outputer output = new Outputer();
		new Thread(new Runnable() {
			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output("zhangxiaoxiang");
				}
			}
		}).start();

		new Thread(new Runnable() {

			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output2("lihuoming");
				}
			}
		}).start();
	}

	static class Outputer {
		public void output(String name) {
			synchronized (this) {
				int len = name.length();
				for (int i = 0; i < len; i++) {
					System.out.print(name.charAt(i));
				}
				System.out.println();
			}
		}
		
		public synchronized void output2(String name) {
				int len = name.length();
				for (int i = 0; i < len; i++) {
					System.out.print(name.charAt(i));
				}
				System.out.println();
		}
		
			}
}

错误代码：

因为一个线程调用的静态方法，即两个线程不是调用的同一个对象，也就说明synchronized不是锁定的同一个对象。

package cn.itcast.heima2;

public class TraditionalTreadSynchrorized {

	public static void main(String[] args) {
		new TraditionalTreadSynchrorized().init();
	}

	public void init() {
		final Outputer output = new Outputer();
		new Thread(new Runnable() {
			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output("zhangxiaoxiang");
				}
			}
		}).start();

		new Thread(new Runnable() {

			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					Outputer.output3("lihuoming");
				}
			}
		}).start();
	}

	static class Outputer {
		public void output(String name) {
			synchronized (this) {
				int len = name.length();
				for (int i = 0; i < len; i++) {
					System.out.print(name.charAt(i));
				}
				System.out.println();
			}
		}
		
		public static synchronized void output3(String name) {
			int len = name.length();
			for (int i = 0; i < len; i++) {
				System.out.print(name.charAt(i));
			}
			System.out.println();
		}

	}
}

正确代码如下：

因为需要锁定静态对象所以要使用Outputer.class

package cn.itcast.heima2;

public class TraditionalTreadSynchrorized {

	public static void main(String[] args) {
		new TraditionalTreadSynchrorized().init();
	}

	public void init() {
		final Outputer output = new Outputer();
		new Thread(new Runnable() {
			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					output.output("zhangxiaoxiang");
				}
			}
		}).start();

		new Thread(new Runnable() {

			@Override
			public void run() {
				while (true) {
					try {
						Thread.sleep(10);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					Outputer.output3("lihuoming");
				}
			}
		}).start();
	}

	static class Outputer {
		public void output(String name) {
			synchronized (Outputer.class) {
				int len = name.length();
				for (int i = 0; i < len; i++) {
					System.out.print(name.charAt(i));
				}
				System.out.println();
			}
		}
		
		public static synchronized void output3(String name) {
			int len = name.length();
			for (int i = 0; i < len; i++) {
				System.out.print(name.charAt(i));
			}
			System.out.println();
		}

	}
}

友情提示：
信息收集于互联网，如果您发现错误或造成侵权，请及时通知本站更正或删除，具体联系方式见页面底部联系我们，谢谢。

其他相似内容：

SigMOD2012感兴趣的论文（时空数据处理）——记下缓缓看

SigMOD2012感兴趣的论文（时空数据处理）——记下慢慢看图中联合做距离数据处理： Efficient Processing of Distance Queries in Larg...
怎的控制你的情绪在项目中，释放压力

怎样控制你的情绪在项目中，释放压力在项目中由于甲方，乙方的关系，涉及到彼此的利益，所以争吵是在所难免的；客户要求你把功能，字段...
ISTQB AL-TM连载系列14：处置缺陷的严重程度与优先级

ISTQB AL-TM连载系列14：处理缺陷的严重程度与优先级正确处理和区分缺陷的严重程度和优先级是所有的软件开发和测试相关人员的重要...
ISTQB AL-TM连载系列11：基于对话的探索性测试管理

ISTQB AL-TM连载系列11：基于会话的探索性测试管理探索性测试是一个特殊的测试过程，它的测试活动和测试内容是动态变化的，更多的是通...
【在线探讨】《用户故事分类与组织结构（一期）》2012-06-26（周二）

【在线研讨】《用户故事分类与组织结构（一期）》2012-06-26（周二）主题：《用户故事分类与组织结构——火星人的需求管理理念（一期）》日期：2...
探索流程的奥秘之三，怎么梳理业务流程

探索流程的奥秘之三，如何梳理业务流程软件开发的难点之一是如何了解客户的需求，现实工作中，开发者们就像瞎子摸象一样从用...
ISTQB AL-TM连载系列13：筹建有效的缺陷管理过程

ISTQB AL-TM连载系列13：搭建有效的缺陷管理过程缺陷是测试过程中的重要输出和工作产品。缺陷的生命周期是一系列的活动和状态所组...
项目经理考虑什么是团队

项目经理思考什么是团队在软件项目实施过程中大家谈的最多的可能是“需求”这个词，之后谈的较多的是“团队”相关的话题。求职者...
通过robbin的管理有关问题谈自己遇到的管理有关问题

通过robbin的管理问题谈自己遇到的管理问题首先澄清每个公司，每个管理团队都有着不同的背景和状况。很多事情都不能一概而论，就和...
loadrunner、QTP、TestDirector学习札记

loadrunner、QTP、TestDirector学习笔记在Windows XP下安装了loadrunner 8.1、QTP 9.2、TestDirector 8.0 运行菜单Samples Set...

守旧线程互斥技术

其他相似内容：

热门推荐：