编程语言
首页 > 编程语言> > Java之多线程的数字加减案例(同步,等待与唤醒)

Java之多线程的数字加减案例(同步,等待与唤醒)

作者:互联网

多线程控制数字的加减:

线程控制数字的加减过程应该是一个加一个减,这个和消费者模型有点像,加了后再减,加减不同同时进行,所以存在同步的问题。

/* 定义一个操作资源
*   这个类用来创建数值和加减切换开关还有加减的操作
*   其它线程类则创建这个类的属性来进行关联,并调用这个类中的方法实现加减的操作。
* */
public class Resource {
    private int num = 0;    // 进行加减操作的数据
    private boolean flag =true; // 加减的切换
    // flag = true : 表示可以进行加法操作,不能减法操作
    // flag = false : 表示可以进行减法操作,不能加法操作
    public synchronized void add(){ // 加法操作,已同步
        if (this.flag == false){    // 现在需要执行的是减法操作,加法操作需要等待
            try {
                super.wait();   // super 表示父类,wait()是Object的方法所以super指向的是Object
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        //延迟
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        this.num ++;
        System.out.println("【加法操作】- " + Thread.currentThread().getName() + ": num = " + this.num);
        // 因为flag = true执行加法,所以将flag设置为false执行减法
        this.flag = false;      // 加法操作执行完毕,需要进行减法操作
        // super 表示父类,notifyAll()是Object的方法所以super指向的是Object
        super.notifyAll();      // 等待的可能是加法或者减法,那么就唤醒全部线程
    }
    public synchronized void sub(){ // 减法操作,已同步
        if (this.flag == true){    // 现在需要执行的是加法操作,减法操作需要等待
            try {
                super.wait();   // super 表示父类,wait()是Object的方法所以super指向的是Object
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        //延迟
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        this.num --;
        System.out.println("【减法操作】- " + Thread.currentThread().getName() + ": num = " + this.num);
        this.flag = true;   // true:执行加法
        super.notifyAll();      // super 表示父类,notifyAll()是Object的方法所以super指向的是Object
    }

}

 

// 加法线程
public class AddThread implements Runnable{
    private Resource resource;
    public AddThread(Resource resource){
        this.resource = resource;
    }

    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            this.resource.add();
        }
    }
}

 

// 减法线程
public class SubThread implements Runnable{
    private Resource resource;
    public SubThread(Resource resource){
        this.resource = resource;
    }

    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            this.resource.sub();
        }
    }
}

 

// 客户端
public class Main {
    public static void main(String[] args) {
        Resource res = new Resource();          //创建资源类对象
        AddThread at = new AddThread(res);      //创建加法线程类对象
        SubThread st = new SubThread(res);      //创建减法线程类对象
        new Thread(at,"加法线程 - A").start();
        new Thread(at,"加法线程 - B").start();
        new Thread(st,"减法线程 - A").start();
        new Thread(st,"减法线程 - B").start();
    }
}

输出结果:

 

num的值最终为0,加减法的交替进行得以验证,但是因为线程优先级的问题,无法保证某一个方法的某个线程先执行。

 

标签:Java,加减,线程,加法,resource,减法,多线程,super,public
来源: https://www.cnblogs.com/0099-ymsml/p/15860542.html