前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >线程的同步

线程的同步

作者头像
用户2965768
发布2019-03-20 10:42:25
4060
发布2019-03-20 10:42:25
举报
文章被收录于专栏:wymwym

为什么要线程同步?

多线程可以同时运行很多资源,但存在安全隐患。

当多个线程访问一块资源时,会产生一些不是预料中的事。

比如买票,有窗口和柜台,窗口卖票和售票机卖票都会减少票的数量,一共100张票,通过窗口这个方法卖了70张票,售票机

这个方法卖了50张票,他们都在线程中,票最后不是变成负数了?

什么是线程同步?

为了解决这个问题,我们就让其中一方先执行(被同步加锁),什么是锁呢

票是大家都可以访问的公享资源,叫临界资源,阻止别人访问临界资源的叫互斥锁,当用了这个synchronized的时候

要使用的线程就获得了这个锁,别的线程没有这个锁只能等待该线程结束再访问临界资源。

如何使用?

使用方法可以像public 那样修饰方法也可以用synchronized(Object){ 代码块 }的格式

实例:

可以看出产生许多脏数据

package defaul;

public class MySynchronized implements Runnable{
	int num = 10;
	
	public static void main(String[] args) {
		MySynchronized mS = new MySynchronized();
		Thread t1 = new Thread(mS,"线程一");
		Thread t2 = new Thread(mS);
		Thread t3 = new Thread(mS);
		Thread t4 = new Thread(mS);
		t1.start();
		t2.start();
		t3.start();
		t4.start();
	}
	
	@Override
	public void run() {
		// TODO Auto-generated method stub
		while(true){
			if(num > 0){
				System.out.println(num--);
				try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}
	}
}

线程同步后

package defaul;

public class MySynchronized implements Runnable{
	int num = 10;
	
	public static void main(String[] args) {
		MySynchronized mS = new MySynchronized();
		Thread t1 = new Thread(mS,"线程一");
		Thread t2 = new Thread(mS);
		Thread t3 = new Thread(mS);
		Thread t4 = new Thread(mS);
		t1.start();
		t2.start();
		t3.start();
		t4.start();
	}
	
	@Override
	public void run() {
		// TODO Auto-generated method stub
		while(true){
			
			synchronized(this){//线程同步代码块
			if(num > 0){
				System.out.println(num--);
				
					try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
				
			}
		}
	}
}

上面代码也可以改成一个方法,然后调用这个方法也是一样的

public synchronized void sell(){
		while(true){
			//线程同步代码块
			if(num > 0){
				System.out.println(num--);				
					try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}
	}
	
	@Override
	public void run() {
		// TODO Auto-generated method stub
		sell();
	}
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2019年03月17日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档