分别使用java和scala写双线程交替修改一个值

素颜马尾好姑娘i 2022-12-14 13:48 82阅读 0赞

第一个线程对该数加1，第二个线程对该数进行减一，假设给定的初始值为10的话，第一个线程的结果为11，第二个线程的结果应为10，然后交替输出

主要实现思路：第一条线程执行加法后，通过notify方法唤醒另一条线程，然后自身进入wait状态  
第二条线程被第一条唤醒后，执行减法操作，执行完毕后通过notify方法唤醒第一条线程，然后自身进入wait状态，等待唤醒  
前提要对当前对象加锁，某一条线程独占后才能实现交替修改  
java实现代码如下：

public class Test2 extends Thread{
        
        private int num;
    
        public Test2( Integer num) {
        
            this.num = num;
        }
    
        public synchronized void add(){
        
            try {
        
                this.num+=1;
                System.out.println(currentThread().getName()+":"+this.num);
                this.notify();
                if(this.num%2==1){
        
                    this.wait();
                }
            } catch (Exception e) {
        
                e.printStackTrace();
            }
        }
        public synchronized void sub(){
        
            try {
        
                this.num-=1;
                System.out.println(currentThread().getName()+":"+this.num);
                this.notify();
                if(this.num%2==0){
        
                    this.wait();
                }
            } catch (InterruptedException e) {
        
                e.printStackTrace();
            }
        }
    
        public static void main(String[] args) {
        
            final Test2 test2 = new Test2(10);
            new Thread(test2,"线程1号") {
        
                @Override
                public void run() {
        
                    while (true){
        
                        test2.add();
                    }
                }
            }.start();
            new Thread(test2,"线程2号"){
        
                @Override
                public void run() {
        
                    while (true){
        
                        test2.sub();
                    }
                }
            }.start();
        }
    }

scala的代码如下：

class Mythread extends Thread{
        
      var num=10
      def add(): Unit ={
        
        this.synchronized{
        
          this.num+=1
          println(this.num)
          this.notify()
          if (this.num%2==1){
        
            this.wait()
          }
        }
      }
      def sub(): Unit ={
        
        this.synchronized{
        
          this.num-=1
          println(this.num)
          this.notify()
          if(this.num%2==0){
        
            this.wait()
          }
        }
      }
    }
    object Mythread{
        
      def main(args: Array[String]): Unit = {
        
        val th = new Mythread
        new Thread(th){
        
          override def run(): Unit = {
        
            while (true){
        
              th.add()
            }
          }
        }.start()
        new Thread(th){
        
          override def run(): Unit = {
        
            while (true){
        
              th.sub()
            }
          }
        }.start()
      }
    }