Java——多线程的同步实现(锁)

谁践踏了优雅 2022-07-13 01:24 206阅读 0赞

# Java——多线程的同步 #

当多个线程同时操作同一个数据的时候，就可能会造成数据不同步的问题，即当一个线程未完成对共享数据的操作时，另一个线程就已经开始了对数据的操作。

所以必须要保证在任何一个时刻只能有一个线程对共享数据进行操作，这就是线程的同步机制。

java中同步机制的实现方式有两种：

>  *  同步代码块
>  *  同步方法

## 1、同步代码块 ##

这里根据上一篇的代码实现了同步代码块

class MyThread2 implements Runnable{
    	int ticket = 100;
    	MyThread2 myThread2 = new MyThread2();//作为锁的对象必须为所有线程共享的对象
    	@Override
    	public void run() {
    		while(true){
    			//使用synchronized关键字将要同步的代码（即操作共享数据的代码）包住，要接受一个同步监视器（锁）作为参数
    			//而锁可以由任何一个类的对象充当，这里使用MyThread2的对象
    			synchronized (myThread2) {
    				if(ticket>0)
    					System.out.println("线程"+Thread.currentThread().getName()+"处理ticket"+ticket--);
    				else
    					break;
    			}
    	}}
    }

## 2、同步方法 ##

class MyThread1 implements Runnable{
    	static int ticket = 100;
    	@Override
    	public void run() {
    		while(true){
    			show();
    			ticket--;
    			if(ticket<0)
    				break;
    		}
    	}
    	//将方法声明为同步的，即将方法加锁，他的锁就是调用该方法的对象，而要保证所有线程的共享一把锁就要保证调用该方法的对象只有一个
    	public synchronized void show(){
    		if(ticket>0)
    			System.out.println("线程"+Thread.currentThread().getName()+"处理ticket"+ticket);
    	}
    }

## 3、使用实例 ##

package com.kexin.study1;
    /**
     * 创建一个银行账户，有两个用户往里面存钱，每人存三次，一次存1000
     * 共享数据：账户
     * 多个线程：两个用户
     * @author KeXin
     *
     */
    class Account{
    	private double money;
    	public synchronized void setMoney(double m){
    		money += m;
    		System.out.println(Thread.currentThread().getName()+"  "+money);
    	}
    }
    class User extends Thread{
    	Account acc;
    	Object obj = new Object();
    	public User(Account acc){
    		this.acc = acc;
    	}
    	public void run() {
    		for(int i =0;i<3;i++){
    				acc.setMoney(1000);
    		}
    	}
    	
    }
    public class TestAccount {
    
    	public static void main(String[] args) {
    		Account acc = new Account();
    		User user1 = new User(acc);
    		User user2 = new User(acc);
    		user1.setName("甲");
    		user2.setName("乙");
    		user1.start();
    		user2.start();
    	}
    
    }