线程间通信

线程间通信

多线程编程步骤(中)

第一,创建资源类,创建属性和操作方法;第二,在资源操作方法,1)判断 2)工作 3)通知;第三,创建多线程调用资源类的方法。

案例

要求,有两个线程,实现对一个初始值为0的变量,一个线程对值+1,一个线程对值-1。

代码实现
/**
 * @author 长名06
 * @version 1.0
 * 线程通信案例 两个线程对一个值进行 decr incr
 * 用synchronized关键字实现
 */

class Share {

    private int number;

    public synchronized void incr() throws InterruptedException {
        /**
         * 这样写,会出现虚假唤醒问题,因为如果当前线程被等待,然后被唤醒时,if语句,就不会再次进行判断
         * 有可能出现,此时的number != 0 当时依旧进行了 +1操作 减方法类似
         * wait()方法再api文档中,就提醒,在一个参数版本中,中断和虚假唤醒是可能的,并且该方法应该始终在循环中使用: 
         * 线程在哪里被阻塞就会在哪里,被唤醒,也就是说线程被阻塞时,是满足number!= 0,所以阻塞,但是因为一个线程执行完后,释		  
         * 放锁,然后唤醒等待的线程,是随机唤醒的,有可能当前+1的条件依旧不满足,但是系统却唤醒了该线程,因为是if语句,在			 
         * this.wait()处被唤醒,程序继续执行,导致其实条件不满足,却执行了+1操作,所以使用while()循环进行判断,只能当条件满		  
         * 足且线程被唤醒才执行incr方法
         * if (number != 0){//条件
         *    this.wait();
         * }
         */
        while (number != 0) {
            this.wait();
        }
        //加1
        number++;
        System.out.println(Thread.currentThread().getName() + "\t" + number);
        //通知其他线程
        this.notifyAll();
    }

    public synchronized void decr() throws InterruptedException {
        while (number != 1) {
            this.wait();
        }
        //减1
        number--;
        System.out.println(Thread.currentThread().getName() + "\t" + number);
        //通知其他线程
        this.notifyAll();
    }
}

public class ThreadDemo {
    public static void main(String[] args) {
        Share share = new Share();

        new Thread(() -> {
            for (int i = 0; i < 25; i++) {
                try {
                    share.incr();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }, "aa").start();

        new Thread(() -> {
            for (int i = 0; i < 25; i++) {
                try {
                    share.decr();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }, "bb").start();
    }
}

多线程编程步骤(下)

第一,创建资源类,创建属性和操作方法;第二,在资源操作方法,1) 判断 2)工作 3)通知;第三,创建多线程调用资源类的方法;第四,防止虚假唤醒问题。

Lock实现上述案例

代码
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * @author 长名06
 * @version 1.0
 */
//第一步创建资源类,属性和操作方法
class ShareByLock {
    private int number;

    //获得锁
    private final ReentrantLock lock = new ReentrantLock();

    //为当前锁,创建一个新的condition,并绑定到该锁上
    private Condition condition = lock.newCondition();

    public void incr() throws InterruptedException {
        //上锁
        lock.lock();
        //第二步 进行
        // 1.判断(线程切换的条件)
        // 2.执行(线程执行的具体操作)
        // 3.通知(唤醒等待的其他线程)
        try {
            //判断
            //第四步 防止虚假唤醒现象
            while (number != 0) {
                condition.await();
            }
            //执行
            number++;
            System.out.println(Thread.currentThread().getName() + "\t" + number);

            //通知
            condition.signalAll();
        } finally {
            //解锁
            lock.unlock();
        }
    }

    public void decr() throws InterruptedException {
        //上锁
        lock.lock();
        try {
            //判断
            while (number != 1) {
                condition.await();
            }
            //执行
            number--;
            System.out.println(Thread.currentThread().getName() + "\t" + number);

            //通知
            condition.signalAll();
        } finally {
            //解锁
            lock.unlock();
        }
    }
}

public class ThreadDemoByLock {
    public static void main(String[] args) {

        ShareByLock shareByLock = new ShareByLock();
        //第三步 创建多个线程调用资源类的方法
        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                try {
                    shareByLock.incr();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }, "aa").start();

        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                try {
                    shareByLock.decr();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }, "bb").start();

        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                try {
                    shareByLock.incr();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }, "cc").start();

        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                try {
                    shareByLock.decr();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }, "dd").start();

    }
}

只是为了记录自己的学习历程,且本人水平有限,不对之处,请指正。

热门相关:仙府之缘   大时代1994   帝国远征   母女的秘密之夜   还在爱爱吗