zoukankan      html  css  js  c++  java
  • 多线程小题

    现在两个线程,可以操作初始值为0的一个变量, 实现一个线程对该变量+1,一个线程-1 ,实现交替来10轮

    判断/干活/通知
    防止虚假唤醒(唤醒以后没判断)

    class AirCondition{
    private int number = 0;
    
    public synchronized void increment()throws Exception{ 
          
          1.判断
          if(number != 0){
                this.wait();
          }
    
          2.干活
          number++;
          sout(mythread)
          3.通知
          this.notifyAll();//唤醒其他等待的线程
          }
    
    public synchronized void decrement()throws Exception{ 
    
          1.判断
          if(number == 0){
                this.wait();
          }
    
          2.干活
          number--;
          sout(mythread)
          3.通知
          this.notifyAll();//唤醒其他等待的线程
          }
    }
    
    main{
    AirCondition airCondition = new AirCondition();
    
    new Thread(()->{
                for(i=1;i<=10;i++){
                      try{airCondition.decrement();}/catch
                }
          },"A").start();
    new Thread(()->{
                for(i=1;i<=10;i++){
                      try{airCondition.decrement();}/catch
                }
          },"B").start();
    
    }
    
    

    在现在这个版本,也就开始拓展ReentrantLock了 可重复递归锁 (非公平锁 锁中嵌套锁)

    class AirCondition
    {
          pulic int number = 0;
          private Lock lock = new ReentrantLock();
          private Condition condition = lock.newCondition();
    
          public void increment() throws Exception
          {
                lock.lock();
                try{
                      判断
                      while(number!=0){
                            condition.await();
                      }
                      干活
                      number++;
                      通知
                      condition.signalAll();
    
                   }catch{}finally{lock.unlock();}
    
          }
    }
    

    synchronized —— wait —— notify

    lock ———— condition(lock.newCondition) ———— condition.await ———— signal(condition)/signal + 标志位

    java 多线程的操作或者获得的方法

    继承Thread类

    实现Runnable接口

    实现Callable接口

    适配器模式:Callable 与 Runnable
    Future就是对于具体的Runnable或者Callable任务的执行结果进行取消、查询是否完成、获取结果。必要时可以通过get方法获取执行结果,该方法会阻塞直到任务返回结果。
    Future类位于java.util.concurrent包下,它是一个接口
    说了半天那怎么使用Callable呢?一般情况下是配合ExecutorService来使用的,在ExecutorService接口中声明了若干个submit方法的重载版本:

    
    <T> Future<T> submit(Callable<T> task);
    <T> Future<T> submit(Runnable task, T result);
    Future<?> submit(Runnable task);
    
    

    第一个submit方法里面的参数类型就是Callable。暂时只需要知道Callable一般是和ExecutorService配合来使用的,具体的使用方法讲在后面讲述。一般情况下我们使用第一个submit方法和第三个submit方法,第二个submit方法很少使用。
    FutureTask类实现了RunnableFuture接口,RunnableFuture继承了Runnable接口和Future接口,而FutureTask实现了RunnableFuture接口,所以它既可以作为Runnable被线程执行,又可以作为Future得到Callable的返回值。
    FutureTask futureTask = new FutureTask(new MyThread()(MyThread implement Callable

  • 相关阅读:
    在aarch版编译libEasyRTSPClient库无法通过问题解决
    视频流媒体推流平台RTMP协议是如何进行网络连接并推送视频流的?
    建立视频直播服务用RTMP协议还是RTSP协议?
    如何搭建RTMP视频流媒体推流服务器
    Winsock Select模型范例
    欢迎大家加入broncho社区与broncho共同发展
    在Windows环境使用Broncho映像[转]
    DirectFB几个辅助工具
    Linux手机研发要过五大难关
    让语言选择即时生效
  • 原文地址:https://www.cnblogs.com/nineberg/p/13535229.html
Copyright © 2011-2022 走看看