java并发编程的艺术-第四章之Java并发基础
博客专区 > wusd1256 的博客 > 博客详情
java并发编程的艺术-第四章之Java并发基础
wusd1256 发表于3个月前
java并发编程的艺术-第四章之Java并发基础
  • 发表于 3个月前
  • 阅读 1398
  • 收藏 53
  • 点赞 3
  • 评论 0

标题:腾讯云 新注册用户域名抢购1元起>>>   

为什么要使用多线程

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虚拟机将会退出。

import java.util.concurrent.TimeUnit;  
  
/** 
 * Created by shidong.wu on 2017/10/13. 
 */  
public class Daemon {  
    public static void main(String[] args) {  
        Thread thread = new Thread(new DaemonRunner(),"DaemonRunner");  
        thread.setDaemon(true);  
        thread.start();  
    }  
    static class DaemonRunner implements Runnable {  
        @Override  
        public void run() {  
            try {  
                TimeUnit.SECONDS.sleep(10);  
            }catch (InterruptedException e) {  
  
            }finally {  
                System.out.println("Daemon finally");  
            }  
        }  
    }  
}  

运行上面的程序终端没有任何输出,主要是因为非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();

 

 

}

 

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


package com.concurrency;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.TimeUnit;

/**
 * Created by shidong.wu on 2017/10/14.
 */
public class WaitNotify {

    private static boolean flag = true;

     private  static Object lock = new Object();

    public static void main(String[] args) throws Exception{
        Thread waitThread = new Thread(new Wait(),"waitThread");
        waitThread.start();
        TimeUnit.SECONDS.sleep(1);

        Thread notifyThread = new Thread(new Notify(),"notifyThread");
        notifyThread.start();
    }


    static class Wait implements Runnable {
        public void run() {
            // 加锁,lock对象加锁
            synchronized (lock) {
                while (flag){  // 条件不满足
                    try {
                        lock.wait();
                    }catch (InterruptedException e){
                    }
                }
                // 条件满足时,进行完成操作
                System.out.println(Thread.currentThread() + new SimpleDateFormat("HH:mm:ss").format(new Date()));
            }
        }
    }

    static class Notify implements Runnable {
        public void run() {
            // 加锁,lock对象加锁
            synchronized (lock) {
                lock.notifyAll(); // 通知
                flag = false;

            }
        }
    }
}


三、join() 使用

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

 

四、ThreadLocal 使用

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

 

 

 

 

标签: java 并发
共有 人打赏支持
粉丝 26
博文 5
码字总数 4914
×
wusd1256
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: