并发编程-多线程基础-CFANZ编程社区

上一篇 <<<安全架构设计方案
下一篇 >>>线程安全与解决方案

多线程： 在同一个进程开启了多条不同的执行路径，每条执行路径就是一个线程，多条不同路径同时执行。

进程和线程区别

单线程和多线程的区别

多线程创建方式

继承Thread
实现Runnable 接口
使用Callable--可以有返回值
线程池--线程的复用机制
@Async注解---存在@Async失效之谜

多线程的特性

原子性

可见性

有序性

int a = 10;    //语句1
int r = 2;    //语句2
a = a + 3;    //语句3
r = a*a;     //语句4
则因为重排序，他还可能执行顺序为 2-1-3-4，1-3-2-4
但绝不可能 2-1-4-3，因为这打破了依赖关系。

多线程的应用场景

分批发送短信
日志记录
比较耗时的业务独立处理
数据库连接池
迅雷多线程下载等。

线程的类型

主线程：main线程/进程线程
守护线程：gc线程 (主线程挂了，守护线程也会被自动销毁.)
用户线程：用户自己创建的线程（主进程关闭后还会继续执行）

public static void main(String[] args) {
    Thread t1 = new Thread(new Runnable() {
        public void run() {
            for(int i=0;i<10;i++){
                System.out.println("子线程 i:"+i);
            }
        }
    });
    t1.start();
    System.out.println("主线程已关闭");
}
主线程已关闭
子线程 i:0
子线程 i:1
子线程 i:2
……

public class DaemonThread {

   public static void main(String[] args) {
      Thread thread = new Thread(new Runnable() {
         public void run() {
            while (true) {
               try {
                  Thread.sleep(100);
               } catch (Exception e) {
                  // TODO: handle exception
               }
               System.out.println("我是子线程...");
            }
         }
      });
      thread.setDaemon(true);
      thread.start();
      for (int i = 0; i < 10; i++) {
         try {
            Thread.sleep(100);
         } catch (Exception e) {

         }
         System.out.println("我是主线程");
      }
      System.out.println("主线程执行完毕!");
   }
}
我是子线程...
我是主线程
主线程执行完毕!

多线程的状态

如何优雅的停止一个线程

// 设置可见性
private volatile boolean flag = true;
public void run() {
    System.out.println(Thread.currentThread().getName());
    // 能保证在线程执行完毕后，才真正的停止一个线程
    while (flag) {

    }
}

public void stopThread() {
    this.flag = false;
}

其他知识

public static void main(String[] args) {
   final Thread t1 = new Thread(new Runnable() {
      public void run() {
         for (int i = 0; i < 5; i++) {
            System.out.println("t1,i:" + i);
         }
      }
   });
   final Thread t2 = new Thread(new Runnable() {
      public void run() {
         try {
            t1.join();
         } catch (Exception e) {
         }
         for (int i = 0; i < 5; i++) {
            System.out.println("t2,i:" + i);
         }
      }
   });
   t1.start();
   t2.start();
}
t1,i:0
t1,i:1
t1,i:2
t1,i:3
t1,i:4
t2,i:0
t2,i:1
t2,i:2
t2,i:3
t2,i:4

public static void main(String[] args) {
    PrioritytThread prioritytThread = new PrioritytThread();
    Thread t1 = new Thread(prioritytThread);
    Thread t2 = new Thread(prioritytThread);
    t1.start();
    // 注意设置了优先级， 不代表每次都一定会被执行。 只是CPU调度会优先分配
    t1.setPriority(10);
    t2.start();
}

多线程产生死锁的原因

死锁诊断

使用jdk自带的jconsole工具即可

相关文章链接：
<<<线程安全与解决方案
<<<锁的深入化
<<<锁的优化
<<<Java内存模型(JMM)
<<<Volatile解决JMM的可见性问题
<<<Volatile的伪共享和重排序
<<<CAS无锁模式及ABA问题
<<<Synchronized锁
<<<Lock锁
<<<AQS同步器
<<<Condition
<<<CountDownLatch同步计数器
<<<Semaphore信号量
<<<CyclicBarrier屏障
<<<线程池
<<<并发队列
<<<Callable与Future模式
<<<Fork/Join框架
<<<Threadlocal
<<<Disruptor框架
<<<如何优化多线程总结