您好,欢迎访问代理记账网站
  • 价格透明
  • 信息保密
  • 进度掌控
  • 售后无忧

多线程通信

要想实现多个线程之间的协同,如:线程执行先后顺序,获取某个线程执行的将结果等等,涉及到线程之间的通信,线程通信主要分为两种方式

  • 共享内存(包括文件共享,网络共享,变量共享):线程之间共享程序的公共状态,线程之间通过写-读内存中的公共状态来隐式进行通信。JAVA实现为:volatile

  • 消息传递:线程之间没有公共状态,线程之间通过发送消息来显式进行通信。例:wait()和notify()。park() 和unpark().

    方法作用备注
    wait()线程调用共享对象的wait()方法后会进入WAITING状态,释放占有的对象锁并等待其他线程的通知或终端才从该方法返回该方法可以传递参数,wait(long n);超时等待n毫秒,进入TIME-WAITING状态,如果在n毫秒内没有通知或终端,则自行返回.
    wait()和notify(),notifyAll()必须在同步代码快中执行
    synchronized (this) {
    try {
    this.wait();
    } catch (InterruptedException e) {
    e.printStackTrace();
    }
    }
    notify()线程调用共享对象的notify()方法后会通知一个调用了wait()方法并再次等待的线程返回.但由于在共享变量商等待的线程可能不止一个,故具体通知哪一个线程是随机的.notifyAll()和notify()方法的作用一致,不过notify()是随机通知一个线程,而notifyAll()则是通知所有在该共享变量商等待的线程
    park()LockSupport类是Java6(JSR166-JUC)引入的一个类,提供了基本的线程同步原语。LockSupport提供的两个主要方法就是park和unpark。LockSupport同步线程和wait/notify不一样,LockSupport并不需要获取对象的监视器,而是给线程一个“许可”(permit)。而permit只能是0或者1。unpark会给线程一个permit,而且最多是1;而park会消耗一个permit并返回,如果线程没有permit则会阻塞。
    unpark()park()和unpark()并不会释放锁
import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.locks.LockSupport;

/**
 * 线程通信
 */
@Slf4j
public class Demo {

    private Object data;

    public static void main(String[] args) throws Exception {
        Demo demo = new Demo();
        //demo.waitNotifyTest();
        demo.parkTest();
    }

    public void waitNotifyTest() throws Exception {

        Thread consumer = new Thread(() -> {
            while (data == null) {
                log.info("此时没有数据,进入等待状态");
                synchronized (this) {
                    try {
                        this.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
            log.info("获取到数据");
        });
        consumer.start();
        log.info("睡眠三秒,模仿生产数据");
        Thread.sleep(3000);
        data = new Object();
        synchronized (this) {
            this.notifyAll();
            log.info("有数据了,通知消费者");
        }
    }

    public void parkTest() throws InterruptedException {

        Thread consumer = new Thread(() -> {
            while (data == null) {
                log.info("此时没有数据,进入等待状态");
                LockSupport.park(Thread.currentThread());
            }
            log.info("获取到数据");
        });
        consumer.start();
        log.info("睡眠三秒,模仿生产数据");
        Thread.sleep(3000);
        data = new Object();
        LockSupport.unpark(consumer);
        log.info("有数据了,通知消费者");
    }
}

分享:

低价透明

统一报价,无隐形消费

金牌服务

一对一专属顾问7*24小时金牌服务

信息保密

个人信息安全有保障

售后无忧

服务出问题客服经理全程跟进