java并发编程的艺术之Java并发基础

为什么要使用多线程

Java天生就是多线程程序,简单的一个main() 方法的执行,其实是由main线程和其它的线程共同执行的。当然使用多线程有如下的好处:

        1、利用更多的处理器核心

        2、更快的响应速度,如将数据一致性不强的操作交给其它的线程去操作

        3、更好的编程模型

线程简介

一、线程优先级

在线程执行过程中,线程优先级决定了需要分配处理器资源的多少,从而决定了获取时间片的多少。现在线程构建时,可以通过setPriority()方法来修改优先级,默认优先级是5.但是在不同的JVM以及操作系统上面,线程的规划有些不同,甚至有些操作系统会忽略对线程优先级的设定,都是采用默认值。

二、线程状态

线程状态

状态名称

说明

NEW

初始状态,线程被创建,还没有有调用start()方法

RUNNABLE

运行状态,java中就绪也属于运行状态

BLOCKED

阻塞状态,表示线程阻塞在进入synchronize修饰的方法或代码块(获取锁)时的状态

WAITING

等待状态,进入该状态表示当前线程需要等待其他的线程做出特定动作(通知、中断)才返回

TIME_WAITING

超时等待,不同于WAITING,它是等到指定时间到达自动返回

TERMINTED

终止状态,表示当前线程执行完成

Daemon 是一种支持线程,主要用来支持程序的后台的调度,所以当Java虚拟机中不存在非Daemon线程(main 线程)时,Java虚拟机将会退出。

1import java.util.concurrent.TimeUnit; 2 3/** 4 * Created by shidong.wu on 2017/10/13. 5 */ 6public class Daemon { 7 public static void main(String[] args) { 8 Thread thread = new Thread(new DaemonRunner(),"DaemonRunner"); 9 thread.setDaemon(true); 10 thread.start(); 11 } 12 static class DaemonRunner implements Runnable { 13 @Override 14 public void run() { 15 try { 16 TimeUnit.SECONDS.sleep(10); 17 }catch (InterruptedException e) { 18 19 }finally { 20 System.out.println("Daemon finally"); 21 } 22 } 23 } 24}

运行上面的程序终端没有任何输出,主要是因为非Daemon线程(main线程)运行结束后,Java虚拟机退出了,所以DaemRunner中的finally代码块没有执行。

三、中断

中断可以理解为线程的一个标识位属性,它标识一个线程是否其它的线程进行的了中断操作。其它的线程通过调用当前线程的interrupt()方法对其进行中断操作。线程通过方法isInterrupt()方法来检查自身是否被中断来进行响应。抛出InterruptException的线程的,他的中断标识会被清除。

线程间通信

一、volatile 和synchronized 关键字

在前面的已经讲过它们的内存含义了,

1、关键字volatile用来修饰一个字段(变量),就是告诉程序任意一个线程,对该变量的读取都要去共享内存中获取,而对变量的修改必须要同步刷新到共享内存里,volatile保证了所有线程的对变量的访问可见性。但是过多的使用volatile,会影响程序的执行效率。

        2、关键字synchronized用来修饰方法和代码块,它主要保证多个线程在同一时刻,只能有一个线程处于synchronized修饰的方法和代码块中,其本质是对一个对象监视器(Monitor)的获取,这个获取的过程是排他的,同一个时刻,只能有一个线程能获取到对象的监视器。没有获取到监视器的线程进入同步队列,等待其他线程释放锁。如下图:

二、等待/通知机制

等待 / 通知机制是指一个线程A调用了对象O的wait()方法,释放锁,进入等待状态,而线程B调用了对象O的notify()或者notifyAll()方法,线程A收到通知后从对象O的wait()方法返回,进而执行后面的操作。

等待 / 通知机制的经典范式,分为,消费者和生产者;

消费者遵循的规范:

1、获取对象的锁

2、如果条件不满足,调用对象的wait()方法,被通知后还要进行条检查

3、条件满足后执行对应的逻辑

对应的伪代码:

synchronized(对象){

while(条件不满足){

对象.wait();

   }

对应的逻辑;

}

生产者遵循的规范:

1、获取对象的锁

2、改变条件

3、通知所有等待在该对象的线程

对此的伪代码:

synchronized (对象) {

改变条件;

       对象.notifyAll();

}

下面我们就利用上面的等待 / 通知的范式实现一个线程的等待/ 通知的机制;

1package com.concurrency; 2 3import java.text.SimpleDateFormat; 4import java.util.Date; 5import java.util.concurrent.TimeUnit; 6 7/** 8 * Created by shidong.wu on 2017/10/14. 9 */ 10public class WaitNotify { 11 12 private static boolean flag = true; 13 14 private static Object lock = new Object(); 15 16 public static void main(String[] args) throws Exception{ 17 Thread waitThread = new Thread(new Wait(),"waitThread"); 18 waitThread.start(); 19 TimeUnit.SECONDS.sleep(1); 20 21 Thread notifyThread = new Thread(new Notify(),"notifyThread"); 22 notifyThread.start(); 23 } 24 25 26 static class Wait implements Runnable { 27 public void run() { 28 // 加锁,lock对象加锁 29 synchronized (lock) { 30 while (flag){ // 条件不满足 31 try { 32 lock.wait(); 33 }catch (InterruptedException e){ 34 } 35 } 36 // 条件满足时,进行完成操作 37 System.out.println(Thread.currentThread() + new SimpleDateFormat("HH:mm:ss").format(new Date())); 38 } 39 } 40 } 41 42 static class Notify implements Runnable { 43 public void run() { 44 // 加锁,lock对象加锁 45 synchronized (lock) { 46 lock.notifyAll(); // 通知 47 flag = false; 48 49 } 50 } 51 } 52} 53

三、join() 使用

如果一个线程A调用了thread.join()表示线程A等待线程thread线程终止之后,才从threa.join()处返回。

四、ThreadLocal 使用

ThreadLocal 是一个线程变量,这个变量是附带在线程上面的。

点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

手写Java HashMap源码

HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22

Java多线程之如何创建多线程?

Java与多线程的关系我们平时写的好多简单程序就有多个线程参与,你可能会感到惊讶,但是事实就是这样。Java程序从main()方法开始执行,然后按照既定的代码逻辑执行,看似没有其他线程参与,但实际上Java程序天生就是多线程程序,因为执行main()方法的是一个名称为main的线程。下面我们来用Java的一个管理类验证一下

KVM调整cpu和内存

一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid

Twitter的分布式自增ID算法snowflake (Java版)

概述分布式系统中,有一些需要使用全局唯一ID的场景,这种时候为了防止ID冲突可以使用36位的UUID,但是UUID有一些缺点,首先他相对比较长,另外UUID一般是无序的。有些时候我们希望能使用一种简单一些的ID,并且希望ID能够按照时间有序生成。而twitter的snowflake解决了这种需求,最初Twitter把存储系统从MySQL迁移