欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Java多线程同步问题

程序员文章站 2022-05-02 12:06:00
...

在前面已经探讨过同步问题https://blog.csdn.net/zsd0819qwq/article/details/101916764

同步

一个多线程的程序,如果是通过Runnable接口实现的,则意味着类中的属性将被多个线程共享,那么这样一来就会造成一种问题,如果这多个线程要操作同一资源的时候就有可能出现资源的同步问题。例如:以之前的卖票程序来讲,如果多个线程同时操作的时候就有可能出现卖出票为负数的问题。

问题的引出

class MyThread implements Runnable{			// 实现Runnable接口
	private int ticket = 5 ;				// 一共5张票
	public void run(){				// 覆写run()方法
		for(int i=0;i<100;i++){			// 超出票数的循环
			if(ticket>0){			// 判断是否有剩余票
				try {
					Thread.sleep(300) ;	// 加入延迟
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				System.out.println("卖票:ticket = " + ticket--) ;
			}
		}
	}
};
public class SyncDemo01 {
	public static void main(String[] args) {
		MyThread mt = new MyThread() ;		// 定义线程对象
		Thread t1 = new Thread(mt) ;			// 定义Thread对象
		Thread t2 = new Thread(mt) ;			// 定义Thread对象
		Thread t3 = new Thread(mt) ;			// 定义Thread对象
		t1.start() ;				// 启动线程
		t2.start() ;				// 启动线程
		t3.start() ;				// 启动线程
	}}

程序的问题

从运行结果可以发现,程序中加入了延迟操作,所以在运行的最后出现了负数的情况,那么为什么现在会产生这样的问题呢?

从上面的操作代码可以发现对于票数的操作步骤如下:

1、 判断票数是否大于0,大于0则表示还有票可以卖

2、 如果票数大于0,则卖票出去

但是,在上面的操作代码中,在第1步和第2步之间加入了延迟操作,那么一个线程就有可能在还没有对票数进行减操作之前,其他线程就已经将票数减少了,这样一来就会出现票数为负的情况

Java多线程同步问题

问题的解决

如果想解决这样的问题,就必须使用同步,所谓的同步就是指多个操作在同一个时间段内只能有一个线程进行,其他线程要等待此线程完成之后才可以继续执行。

Java多线程同步问题Java多线程同步问题

解决资源共享的同步操作,可以使用同步代码块和同步方法两种方式完成。

同步代码块

在代码块上加上“synchronized”关键字的话,则此代码块就称为同步代码块。

同步代码块格式:

synchronized(同步对象){

  需要同步的代码 ;

}

使用同步代码块解决以上的同步问题

class MyThread implements Runnable{		// 实现Runnable接口
	private int ticket = 5 ;			// 一共5张票
	public void run(){				// 覆写run()方法
		for(int i=0;i<100;i++){			// 超出票数的循环
			synchronized (this) {		// 设置需要同步的操作	
				if(ticket>0){		// 判断是否有剩余票
					try {
						Thread.sleep(300) ;	// 加入延迟
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				    System.out.println("卖票:ticket = " + ticket--) ;
				}
			}
		}
	}
};

同步方法

除了可以将需要的代码设置成同步代码块之外,也可以使用synchronized关键字将一个方法声明成同步方法。

同步方法定义格式:

synchronized 方法返回值 方法名称(参数列表){}

使用同步方法解决以上问题

class MyThread implements Runnable{		// 实现Runnable接口
	private int ticket = 5 ;			// 一共5张票
	public void run(){				// 覆写run()方法
		for(int i=0;i<100;i++){			// 超出票数的循环
			this.sale();			// 调用同步方法
		}
	}
	public synchronized void sale() {		// 声明同步方法
		if(ticket>0){				// 判断是否有剩余票
			try {
				Thread.sleep(300) ;	// 加入延迟
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			System.out.println("卖票:ticket = " + ticket--) ;
		}
	}
};

方法定义的完整格式

下面就可以给出Java中方法定义的完整格式了:

访问权限{public|default|protected|private} [final] [static] [synchronized] 返回值类型|void 方法名称(参数类型 参数名称,…..) [throws Exception1,Exception2]{

       [return [返回值|返回调用处]] ;

  }