zoukankan      html  css  js  c++  java
  • NO.7多个线程之间共享数据的方式探讨

    1.如果每个现场执行的代码相同,可以使用同一个Runnable对象,这个Runnable对象中有那个共享数据,例如:买票系统就可以这个干。

    2.如果每个现场执行代码不同,这时候需要不同的Runnable对象,有如下两种方式来实现这些Runnable对象之间的数据共享

        a.将共享数据封装在另外一个对象中,然后将这个对象逐一传递给各个Runnable对象。

    这个线程对共享数据的操作方法也分配到那个对象身上去完成,这样容易实现针对该数据进行的各个操作的互斥和通信。

       b.将这些Runnable对象作为某一个类中的内部类,共享数据作为这个外部类中的成员变量,每个线程对共享数据的操作方法也分配给外部类,以便实现对共享

    数据进行的各个操作的互斥和通信,作为内部类的各个Runnable对象调用外部类的这些方法

      c.上面两种方式的组合:将共享数据封装在另外一个对象中,每个线程对共享数据的操作方法也分配到那个对象身上完成,对象作为这个外部类中的成员变量

    或方法中的局部变量,每个线程的Runnable对象作为外部类中的成员内部类或局部内部类。

      d.总之,要同步互斥的几段代码最好是分别放在几个独立的方法中,这些方法再放在同一个类中,这样比较容易实现他们之间的同步互斥和通信。

     代码一、

    package thread;
    
    public class MultiThreadShareData {
        
        public static void main(String[] args) {
            
            final ShareData1 data1 = new ShareData1();
            
            new Thread(new Runnable() {
                @Override
                public void run() {
                    data1.decrement();
                }
            }).start();
            
            new Thread(new Runnable() {
                @Override
                public void run() {
                    data1.increment();
                }
            }).start();
        
        }
        
        
    }
    class ShareData1 {
        
        private int j = 0;
        
        public synchronized void increment() {
            j ++;
        }
        
        public synchronized void decrement() {
            j --;
        }
        
    }

    代码二、

    package thread;
    
    public class MultiThreadShareData {
        
        public static void main(String[] args) {
            
            final ShareData1 data1 = new ShareData1();
            
            new Thread(new MyRunnable1(data1)).start();
            new Thread(new MyRunnable2(data1)).start();
        
    }
    }
    class MyRunnable1 implements Runnable{
        
        private ShareData1 data1;
        
        public MyRunnable1(ShareData1 data1) {
            this.data1 = data1;
        }
        
        @Override
        public void run() {
            data1.decrement();
        }
        
    }
    class MyRunnable2 implements Runnable{
        
        private ShareData1 data1;
        
        public MyRunnable2(ShareData1 data1) {
            this.data1 = data1;
        }
        
        @Override
        public void run() {
            data1.increment();
        }
        
    }
    
    class ShareData1 {
        
        private int j = 0;
        
        public synchronized void increment() {
            j ++;
        }
        
        public synchronized void decrement() {
            j --;
        }
        
    }

    代码三、仅仅是全局变量和局部变量的区别

    package thread;
    
    public class MultiThreadShareData {
        
        
        private static ShareData1 data1 = new ShareData1();
        
        public static void main(String[] args) {
            /**
             * code 2
             */
            new Thread(new MyRunnable1(data1)).start();
            new Thread(new MyRunnable2(data1)).start();
        }
    }
    class MyRunnable1 implements Runnable{
        
        private ShareData1 data1;
        
        public MyRunnable1(ShareData1 data1) {
            this.data1 = data1;
        }
        
        @Override
        public void run() {
            data1.decrement();
        }
        
    }
    class MyRunnable2 implements Runnable{
        
        private ShareData1 data1;
        
        public MyRunnable2(ShareData1 data1) {
            this.data1 = data1;
        }
        
        @Override
        public void run() {
            data1.increment();
        }
        
    }
    
    class ShareData1 {
        
        private int j = 0;
        
        public synchronized void increment() {
            j ++;
        }
        
        public synchronized void decrement() {
            j --;
        }
        
    }
     
  • 相关阅读:
    第一个小程序-简单计算器
    You have to be inside an angular-cli project in order to use the serve command.
    执行命令npm install typescript@2.3.1 --save-dev,发现了不得了的东西
    安装gulp或者npm淘宝镜像cnpm时出现错误,proxy was not installed probaly
    @angular/compiler-cli@4.3.6 requires typescript@'>=2.1.0 <2.4.0' but 2.5.2 was found instead.
    The "@angular/compiler-cli" package was not properly installed. Error: TypeError: Cannot read property 'Private' of undefined
    angula安装各种包出现"Please try running this command again as root/Administrator."的解决方法
    The “@angular/compiler-cli” package was not properly installed
    关于angular开发中报错Cannot find module 'webpack/lib/node/NodeTemplatePlugin'问题的解决办法若干
    psql:定位慢查询
  • 原文地址:https://www.cnblogs.com/royi123/p/3123075.html
Copyright © 2011-2022 走看看