zoukankan      html  css  js  c++  java
  • 《Java多线程编程核心技术》学习笔记

    第2章 对象及变量的并发访问

    2.1 synchronized同步方法

    方法内的变量为线程安全:

      方法内部的变量是线程私有的

      方法中有一个变量num,后面对它赋值

      两个线程同时调用这个方法,对其赋不同的值,不会出现非线程安全的问题

    实例变量非线程安全:

      多个线程共同访问一个对象中的实例变量,则会出现非线程安全的问题

      对方法加上synchrongized,则可以解决该问题

    多个对象多个锁:

      两个线程访问不同对象的方法,则是线程安全的

      即使获得了锁,也不会同步,因为不是用一个对象的锁

      A线程先持有object对象的Lock锁,B线程可以以异步的方式调用object对象中的非synchronized类型的方法。

      A线程先持有object对象的Lock锁,B线程如果在这时调用object对象中的synchronized类型的方法则需等待,也就是同步。

    synchronized锁重入

      关键字synchronized拥有锁重入的功能,也就是在使用synchronized时,当一个线程得到一个对象锁后,再次请求此对象锁时是可以再次得到该对象的锁的。

      这也证明在一个synchronized方法/块的内部调用本类的其他synchronized方法/块时,是永远可以得到锁的。

      可重入锁也支持在父子类继承的环境中。

    出现异常,锁自动释放

    同步不具有继承性

    2.2 synchronized同步语句块

      synchronized声明方法在某些情况下是有弊端的,比如A线程调用同步方法执行一个长时间的任务,那么B线程则必须等待较长的时间,在这种情况下可以使用同步语句块来解决。

      当一个线程访问object的一个synchronized同步代码块时,另一个线程仍然可以访问该object对象中的非synchronized(this)同步代码块。

      当一个线程访问object的一个synchronized(this)同步代码块时,其他线程对同一个object中所有其他synchronized(this)同步代码块的访问将被堵塞,这说明synchronized使用的“对象监视器”是一个。

      如果使用同步代码块锁定非this对象,则不会与其他硕this同步方法争抢this锁。

      synchronized加到静态方法上,是给Class类加锁,加到非静态方法上,是给对象加锁

      程序设计时要避免双方互相持有对方的锁的情况,避免死锁。

    2.3 volatile关键字

      一个线程执行while(flag)的无限循环,主线程再将flag置为false,还是有可能出现死循环,解决办法是用volatile

      在JVM -server模式中,为了线程运行的效率,线程一直在私有堆栈中获取flag的值为true,主线程修改的是公共堆栈中的flag

      使用volatile关键字,强制从公共内存中读取变量的值 

    关键字synchronized和volatile进行一下比较: 

      关键字volatile只能修饰变量,而synchronized可以修饰方法,以及代码块,随着JDK新版本的发布,synchronized关键字在执行效率上得到很大的提升,在开发中时用synchronized关键字的比率还是比较大的。

      多线程访问volatile不会发生堵塞,而synchronized会出现堵塞。

      volatile能保证数据的可见性,但不能保证原子性,而synchronized可以保证原子性,也可以间接保证可见性,因为它会将私有内存和公共内存中的数据做同步。

      关键字volatile解决的是变量在多个线程之间的可见性,而synchronized关键字解决的是多个线程之间访问资源的同步性。

    使用原子类进行i++ :

      除了在i++操作是使用synchronized关键字实现同步外,还可以使用AtomicInteger原子类进行实现。 

      原子操作是不能分割的整体,没有其他线程能够中断或检查正在原子操作中的变量。一个原子类型就是一个原子操作可用的类型,它可以在没有锁的情况下做到线程安全。

     


      关键字synchronized可以保证在同一时刻,只有一个线程可以执行某一个方法或某一个代码块。

      它包含两个特征:互斥性和可以见性。同步synchronized不仅可以解决一个线程看到的对象处于不一致的状态,还可以保证进入同步方法或者同步代码块的每个线程,都看到由同一个锁保护之前所有的修改效果。

    第3章 线程间通信

    3.1 等待/通知机制

    wait():

      在调用wait()方法之前,线程必须获得该对象的对象级别锁,即只能在同步方法或同步块中调用wait()方法。

      wait()方法是Object类的方法,该方法用来将当前线程置入“预执行队列”中,并且在wait()所在的代码行处停止执行,直到接到通知或被中断为止。

      在执行wait()方法后,当前线程释放锁。(sleep不会释放锁。)

    notify():

      方法notify()也要在同步方法或同步块中调用,即在调用前,线程也必须获得该对象的对象级别锁

      该方法用来通知那些可能等待该对象锁的其他线程,如果有多个线程等待,则由线程规划器随机挑选出其中一个呈wait状态的线程,对其发出通知notify,并使它等待获取该对象的对象锁。

      在执行notify()方法后,当前线程不会马上释放该对象锁,要等到执行notify()方法的线程将程序执行完,也就是退出synchronized代码块后,当前线程才会释放锁,而呈wait状态所在的线程才可以获取该对象锁。

    总结:

      wait 使线程停止运行,notify 使停止的线程继续运行。

      wait ()方法可以使调用该方法的线程释放共享资源的锁,从运行状态退出,进入等待状态,直到再次被唤醒。

      notify() 方法可以随机唤醒等待队列中等待同一共享资源一个线程,并使该线程退出等待状态,进入可运行状态

      notifyAll() 方法可以随机唤醒等待队列中等待同一共享资源的所有线程,并使这些线程退出等待状态,进入可运行状态。

    线程状态:

      新创建一个线程对象后,调用它的 start() 方法,系统会为此线程分配 CPU 资源,使其处于 Runnable(可运行)状态,如果线程抢占到 CPU 资源,此线程就会处于 Running (运行)状态

      Runnable 和 Running 状态之间可以相互切换,因为线程有可能运行一段时间后,有其他优先级高的线程抢占了 CPU 资源,此时线程就从 Running 状态变成了 Runnable 状态。

      线程wait()之后,调用线程对象的interrupt()方法会出现异常。

      wait(long):等待某一时间内是否有线程对锁进行唤醒,超过这个时间则自动唤醒。

    生产者消费者问题:

      用wait和notify的话,注意使用循环和notifyAll

    通过管道进行线程间通信:

      字节流:PipedInputStream,PipedOutputStream

      字符流:PipedReader,PipedWriter

    3.2 join

      使所属的线程对象x正常执行run(),当前线程z无限期阻塞,等待线程x被销毁后再执行线程z。

      join 方法具有使线程排队运行的作用,有些类似同步的运行效果。

      join 与 synchronized 的区别是:join 在内部使用 wait() 方法进行等待,而 synchronized 关键字使用的是 “对象监视器” 原理做为同步。

      在 join 过程中,如果当前线程对象被中断,则当前线程出现异常。

      方法 join(long) 中的参数是设定等待的时间。

      join(long)在内部是使用wait(long)实现的,所以这个方法会释放锁,而sleep(long)不会释放锁。

      t.join()方法阻塞调用此方法的线程(calling thread),直到线程t完成,此线程再继续;

      通常用于在main()主线程内,等待其它线程完成再结束main()主线程。例如:

     1 public class JoinTester01 implements Runnable {
     2 
     3     private String name;
     4 
     5     public JoinTester01(String name) {
     6     this.name = name;
     7     }
     8 
     9     public void run() {
    10     System.out.printf("%s begins: %s
    ", name, new Date());
    11     try {
    12         TimeUnit.SECONDS.sleep(4);
    13     } catch (InterruptedException e) {
    14         e.printStackTrace();
    15     }
    16     System.out.printf("%s has finished: %s
    ", name, new Date());
    17     }
    18 
    19     public static void main(String[] args) {
    20     Thread thread1 = new Thread(new JoinTester01("One"));
    21     Thread thread2 = new Thread(new JoinTester01("Two"));
    22     thread1.start();
    23     thread2.start();
    24     
    25     try {
    26         thread1.join();
    27         thread2.join();
    28     } catch (InterruptedException e) {
    29         // TODO Auto-generated catch block
    30         e.printStackTrace();
    31     }
    32     
    33     System.out.println("Main thread is finished");
    34     }
    35 
    36 }

    3.3 ThreadLocal

      解决的是变量在不同线程间的隔离性,也就是不同线程拥有自己的值。

    3.4 InheritableThreadLocal 

      可以在子线程中取得父线程继承下来的值。

    第4章 Lock 的使用

    4.1 使用 ReentrantLock 类

    使用下面代码获取ReenTrantLock对象lock:

      private Lock lock = new ReentrantLock();

      调用lock.lock()方法可以对代码进行加锁,调用lock.unlock()方法对代码进行解锁。

      调用了lock()方法代码的线程会持有“对象监视器”,其他线程只有等待锁被释放时再次争抢,效果跟使用synchronized关键字一样,线程间还是顺序执行的。

    Condition:

      类ReentrantLock实现等待/同步功能,需要借助于condition对象。

      Condition类具有很好的灵活性,可以实现多路通知功能:在一个Lock对象中创建多个Condition(对象监视器)实例,线程对象可以注册在指定的Condition中,从而有选择性地进行线程通知,在调度线程上更灵活。

      在使用notify()/notifyAll()方法进行通知时,被通知的线程是由JVM随机选择的,但使用ReentrantLock结合Condition类是可以实现前面介绍过的“选择性通知”,这个功能是常用,且在Condition中是默认的。

      synchronized相当于整个Lock对象中只有一个单一的condition对象,所有线程都注册在他一个对象上。

      Object类中的wait()方法相当于Condition类中的await()方法。

      Object类中的wait(long timeout)方法相当于Condition类中的await(long time, TimeUnit unit)方法。

      Object类中的notify()方法相当于Condition类中的single()方法。

      Object类中的notifyAll()方法相当于Condition类中的singleAll()方法。

    公平锁与非公平锁:

      公平锁:标识线程获取锁的顺序是按照线程加锁的顺序来分配的,即先来先得的FIFO先进先出顺序。

      非公平锁(默认):一种线程抢占机制,是随机获取锁的,和公平锁不一样的就是先来的不一定先得到锁,这个方法可能会导致某些线程一直拿不到锁,自然不公平。

      创建的方式就是:

      private Lock lock = new ReentrantLock(Boolean flag);

      flag为true就是公平锁,flag为false就是非公平锁。

    ReentrantLock类的API:

      int getHoldCount() :查询当前线程保持此锁定的个数,也就是调用lock()方法的次数。

      int getQueueLength():返回正等待获取此锁定线程估计数。

      int getWaitQueueLength(Condition condition):返回等待与此锁定相关的给定条件Condition的线程估计数。

          比如有5个线程,每个线程都执行了同一个condition对象的await()方法,则调用getWaitQueueLength()返回的值就是5。

      boolean hasQueuedThread(Thread thread):查询指定的线程是否正在等待获取此锁定。  

      boolean hasQueuedThreads():查询是否有线程正在等待获取此锁定。

      boolean hasWaiters(Condition condition):查询是否有线程正在等待与此锁定有关的condition条件。

      boolean isFair():判断是不是公平锁

      boolean isHeldByCurrentThread():查询当前线程是否保持此锁定

      boolean isLocked():查询此锁定是否由任意线程保持

      void lockInterruptibly():如果当前线程未被中断(不处于中断状态),则获得锁定,如果已经被检测中断(处于中断状态)则出现异常。

      boolean tryLcok():仅在调用时锁定未被另一个线程保持的情况下,才获得该锁定。

      boolean tryLock(long timeout, TimeUnit unit):如果锁定在给定等待时间内没有被另一个线程保持,且当前线程未被中断,则获得该锁定。

    condition的API:

      awaitUninterruptibly():此方法为condition的方法await()的替代。可以避免在挂起的时候遇到打断状态(interrupt)而爆出异常。

      awaitUntil():在指定时间后唤醒自己。参数为long。在线程等待期间也可以被其他线程唤醒。

      

    4.2 使用 ReentrantReadWriteLock 类

      读写锁:一个是读操作相关的锁,也成为共享锁;另一个是写操作相关的锁,也叫排他锁。

      读锁之间不互斥,读锁与写锁互斥,写锁与写锁互斥。

      在没有线程进行写操作时,多个进行读操作的线程都可以获取读锁,而进行写入操作的Thread只有在获取写锁后才能进行写入操作。

      多个线程可以同时进行读操作,但同一时刻只允许一个Thread进行写入操作。 

    可以通过如下代码获取读写锁:

      private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();

      lock.readLock().lock():可以获得读锁,并进行加锁。

      lock.writeLock().lock():就可以获得写锁,并进行加锁。

     

  • 相关阅读:
    图形学基础教程09--骨骼动画原理 (带演示程序)
    图形学基础教程08--光栅化原理
    图形学基础教程07--渲染到纹理 (带演示程序)
    图形学基础教程06--渲染状态二 (带演示程序)
    图形学基础教程05--渲染状态一 (带演示程序)
    图形学基础教程04--纹理和采样器 (带演示程序)
    图形学基础教程03--矩阵变换和光照 (带演示程序)
    图形学基础教程02--顶点数据和SHADER寄存器 (带演示程序)
    图形学基础教程01--渲染管线 (带演示程序)
    Jquery 全选、反选问题解析
  • 原文地址:https://www.cnblogs.com/mengchunchen/p/9096547.html
Copyright © 2011-2022 走看看