一、技术点

1. 线程与进程

在开始之前先把进程与线程进行区分一下,一个程序最少需要一个进程,而一个进程最少需要一个线程。关系:线程->进程->程序的大致组成结构。所以线程是程序运行的最小组成单位,而进程是系统进行资源分配和调度的一个独立单位。以下我们所有讨论的都是建立在线程基础之上。

2. Thread的几个重要方法

a. start()方法:调用该方法开始执行该线程;
b. stop()方法:调用该方法强制结束该线程执行
c. join()方法:调用该方法等待该线程结束
d.yield()方法: 使当前线程让出CPU,但该线程会再次抢夺CPU
e.sleep()方法:调用该方法该线程进入等待
f.run()方法,调用该方法直接执行线程的run()方法,但是线程调用start()方法时也会运行run()方法,区别就是一个是由线程调度运行run()方法,一个是直接调用了线程中的run()方法!!
注意:看到这里,可能有些人就会问啦,那wait()和notify()呢?要注意,其实wait()与notify()方法是Object的方法,不是Thread的方法!!同时,wait()与notify()会配合使用,分别表示线程挂起和线程恢复。
sleep()和wait方法的区别:

wait sleep
同步 只能在同步上下文调用wait方法,否则或抛出IllegaIMonitorStateException异常 不需要在同步方法或者同步块中调用
作用对象 wait方法定义在Object类中,作用于对象本身 sleep方法定义于Thread中,作用于当前线程
释放锁资源
唤醒条件 其他线程调用对象的notify()或者notifyAll()方法 超时或者调用interrupt方法体
方法属性 wait是实例方法 sleep是静态方法

3. 线程状态

线程总共有5大状态:

  • 新建状态:新建线程对象,并没有调用start()方法之前
  • 就绪状态:调用start()方法之后线程就进入就绪状态,但是并不是说只要调用start()方法线程就马上变为当前线程,在变为当前线程之前都是为就绪状态。值得一提的是,线程在睡眠和挂起中恢复的时候也会进入就绪状态哦。
  • 运行状态:线程被设置为当前线程,开始执行run()方法。就是线程进入运行状态
  • 阻塞状态:线程被暂停,比如说调用sleep()方法后线程就进入阻塞状态
  • 死亡状态:线程执行结束

    4. 锁类型

  • 可重入锁:在执行对象中所有同步方法不用再次获得锁

  • 可中断锁:在等待获取锁过程中可中断
  • 公平锁: 按等待获取锁的线程的等待时间进行获取,等待时间长的具有优先获取锁权利
  • 读写锁:对资源读取和写入的时候拆分为2部分处理,读的时候可以多线程一起读,写的时候必须同步地写

    二、synchronized和Lock的区别

    1. 区别分类:

    | 类别 | synchronized | Lock | | —- | —- | —- | | 存在层次 | Java的关键字,在Jvm层面上 | 是一个类 | | 锁的释放 | 1、以获取锁的线程执行完同步代码,释放锁.2、线程执行发生异常,Jvm会让线程释放锁 | 在finally中必须释放锁,不然容易造成线程死锁 | | 锁的获取 | 假设A线程获取锁,B线程等待。如果A线程阻塞,B线程会一直等待 | 分情况而定,Lock有多个锁获取的方式,具体下面会说道,大致就是可以尝试获取锁,线程可以不用一直等待 | | 锁状态 | 无法判断 | 可以判断 | | 锁类型 | 可重入锁,不可中断,非公平 | 可重入,可判断,可公平(两者皆可) | | 性能 | 少量同步 | 大量同步 |

三、Lock详细介绍和Demo

Lock的部分源码:

  1. public interface Lock {
  2. /**
  3. * Acquires the lock.
  4. */
  5. void lock();
  6. /**
  7. * Acquires the lock unless the current thread is
  8. * {@linkplain Thread#interrupt interrupted}.
  9. */
  10. void lockInterruptibly() throws InterruptedException;
  11. /**
  12. * Acquires the lock only if it is free at the time of invocation.
  13. */
  14. boolean tryLock();
  15. /**
  16. * Acquires the lock if it is free within the given waiting time and the
  17. * current thread has not been {@linkplain Thread#interrupt interrupted}.
  18. */
  19. boolean tryLock(long time, TimeUnit unit) throws InterruptedException;
  20. /**
  21. * Releases the lock.
  22. */
  23. void unlock();
  24. }

Lock的主要方法:

  • lock():获取锁,如果锁被暂用则一直等待
  • unlock():释放锁
  • tryLock(): 注意返回类型是boolean,如果获取锁的时候锁被占用就返回false,否则返回true
  • tryLock(long time, TimeUnit unit):比起tryLock()就是给了一个时间期限,保证等待参数时间
  • lockInterruptibly():用该锁的获得方式,如果线程在获取锁的阶段进入了等待,那么可以中断此线程,先去做别的事

通过 以上的解释,大致可以解释在上个部分中“锁类型(lockInterruptibly())”,“锁状态(tryLock())”等问题,还有就是前面子所获取的过程我所写的“大致就是可以尝试获得锁,线程可以不会一直等待”用了“可以”的原因。

lock():

  1. package com.brickworkers;
  2. import java.util.concurrent.locks.Lock;
  3. import java.util.concurrent.locks.ReentrantLock;
  4. public class LockTest {
  5. private Lock lock = new ReentrantLock();
  6. //需要参与同步的方法
  7. private void method(Thread thread){
  8. lock.lock();
  9. try {
  10. System.out.println("线程名"+thread.getName() + "获得了锁");
  11. }catch(Exception e){
  12. e.printStackTrace();
  13. } finally {
  14. System.out.println("线程名"+thread.getName() + "释放了锁");
  15. lock.unlock();
  16. }
  17. }
  18. public static void main(String[] args) {
  19. LockTest lockTest = new LockTest();
  20. //线程1
  21. Thread t1 = new Thread(new Runnable() {
  22. @Override
  23. public void run() {
  24. lockTest.method(Thread.currentThread());
  25. }
  26. }, "t1");
  27. Thread t2 = new Thread(new Runnable() {
  28. @Override
  29. public void run() {
  30. lockTest.method(Thread.currentThread());
  31. }
  32. }, "t2");
  33. t1.start();
  34. t2.start();
  35. }
  36. }
  37. //执行情况:线程名t1获得了锁
  38. // 线程名t1释放了锁
  39. // 线程名t2获得了锁
  40. // 线程名t2释放了锁

tryLock():

  1. package com.brickworkers;
  2. import java.util.concurrent.locks.Lock;
  3. import java.util.concurrent.locks.ReentrantLock;
  4. public class LockTest {
  5. private Lock lock = new ReentrantLock();
  6. //需要参与同步的方法
  7. private void method(Thread thread){
  8. /* lock.lock();
  9. try {
  10. System.out.println("线程名"+thread.getName() + "获得了锁");
  11. }catch(Exception e){
  12. e.printStackTrace();
  13. } finally {
  14. System.out.println("线程名"+thread.getName() + "释放了锁");
  15. lock.unlock();
  16. }*/
  17. if(lock.tryLock()){
  18. try {
  19. System.out.println("线程名"+thread.getName() + "获得了锁");
  20. }catch(Exception e){
  21. e.printStackTrace();
  22. } finally {
  23. System.out.println("线程名"+thread.getName() + "释放了锁");
  24. lock.unlock();
  25. }
  26. }else{
  27. System.out.println("我是"+Thread.currentThread().getName()+"有人占着锁,我就不要啦");
  28. }
  29. }
  30. public static void main(String[] args) {
  31. LockTest lockTest = new LockTest();
  32. //线程1
  33. Thread t1 = new Thread(new Runnable() {
  34. @Override
  35. public void run() {
  36. lockTest.method(Thread.currentThread());
  37. }
  38. }, "t1");
  39. Thread t2 = new Thread(new Runnable() {
  40. @Override
  41. public void run() {
  42. lockTest.method(Thread.currentThread());
  43. }
  44. }, "t2");
  45. t1.start();
  46. t2.start();
  47. }
  48. }
  49. //执行结果: 线程名t2获得了锁
  50. // 我是t1有人占着锁,我就不要啦
  51. // 线程名t2释放了锁

前面比较重提到“公平锁”,在这里可以提一下ReentrantLock对于平衡锁的定义,在源码中有这么两段:

  1. /**
  2. * Sync object for non-fair locks
  3. */
  4. static final class NonfairSync extends Sync {
  5. private static final long serialVersionUID = 7316153563782823691L;
  6. /**
  7. * Performs lock. Try immediate barge, backing up to normal
  8. * acquire on failure.
  9. */
  10. final void lock() {
  11. if (compareAndSetState(0, 1))
  12. setExclusiveOwnerThread(Thread.currentThread());
  13. else
  14. acquire(1);
  15. }
  16. protected final boolean tryAcquire(int acquires) {
  17. return nonfairTryAcquire(acquires);
  18. }
  19. }
  20. /**
  21. * Sync object for fair locks
  22. */
  23. static final class FairSync extends Sync {
  24. private static final long serialVersionUID = -3000897897090466540L;
  25. final void lock() {
  26. acquire(1);
  27. }
  28. /**
  29. * Fair version of tryAcquire. Don't grant access unless
  30. * recursive call or no waiters or is first.
  31. */
  32. protected final boolean tryAcquire(int acquires) {
  33. final Thread current = Thread.currentThread();
  34. int c = getState();
  35. if (c == 0) {
  36. if (!hasQueuedPredecessors() &&
  37. compareAndSetState(0, acquires)) {
  38. setExclusiveOwnerThread(current);
  39. return true;
  40. }
  41. }
  42. else if (current == getExclusiveOwnerThread()) {
  43. int nextc = c + acquires;
  44. if (nextc < 0)
  45. throw new Error("Maximum lock count exceeded");
  46. setState(nextc);
  47. return true;
  48. }
  49. return false;
  50. }
  51. }

从以上源码可以看出在Lock中可以自己控制锁是否公平,而且,默认的是非公平锁,以下是ReentrantLock的构造函数:

  1. public ReentrantLock() {
  2. sync = new NonfairSync();//默认非公平锁
  3. }