目录
1、什么是线程、多线程、并行、并发?2、为什么应用多线程?3、怎么创立线程?4、怎么保障线程平安?5、线程如何调度的?6、线程分类?7、其它
一、什么是线程、多线程?
首先咱们先理解下,程序、过程:程序:是一组计算机能辨认和执行的指令,运行于电子计算机上,满足人们某种需要的信息化工具。过程:正在运行的一个应用程序,是一个动静的过程,有它本身的产生,存在和沦亡的过程。(领有独立的内存空间)(例如:运行一个word.exe软件,就是一个过程)线程:过程可进一步细化为线程,是一个程序外部的一条执行办法,有本人独立的工作内存(栈)和共享内存(堆)。(从宏观角度上了解线程是并行运行的,然而从宏观角度上剖析却是串行运行的,即一个线程一个线程的去运行,当零碎只有一个CPU时,线程会以某种程序执行多个线程,咱们把这种状况称之为线程调度。工夫片即CPU调配给各个程序的运行工夫(很小的概念))多线程:指的是这个过程运行时产生了不止一个线程。并行:指两个或多个事件在同一时刻点产生。(计算机系统中有多个CPU,则这些能够并发执行的程序便可被调配到多个处理器上,实现多任务并行执行,即利用每个处理器来解决一个可并发执行的程序,这样,多个程序便能够同时执行,因为是宏观的,所以大家在应用电脑的时候感觉就是多个程序是同时执行的。)并发:指两个或多个事件在同一时间段内产生。(在单CPU零碎中,每一时刻却仅能有一道程序执行(工夫片),故宏观上这些程序只能是分时地交替执行。)
二、为什么要应用多线程?
用线程只有一个目标,那就是更好的利用cpu的资源,因为所有的多线程代码都能够用单线程来实现。
三、怎么创立线程?
1、继承Thread类
步骤:1):定义一个类A继承于java.lang.Thread类.2):在A类中笼罩Thread类中的run办法.3):咱们在run办法中编写须要执行的操作---->run办法里的,线程执行体.4):在main办法(线程)中,创立线程对象,并启动线程.留神:启动线程,必须用start()办法,这样才能够创立线程,不可间接调用run()办法,这样无奈创立线程,只是你在main办法调用了run()办法,都只是main线程执行,没有创立新线程。
生产者与消费者例子(继承Thread版):
package com.example.gxw.Thread; import android.view.Window; /** * * 创立三个窗口卖票,总票数为100张,应用继承自Thread形式 * 用动态变量保障三个线程的数据独一份 * * 存在线程的平安问题,有待解决 * * */ public class ThreadDemo extends Thread{ public static void main(String[] args){ window t1 = new window(); window t2 = new window(); window t3 = new window(); t1.setName("售票口1"); t2.setName("售票口2"); t3.setName("售票口3"); t1.start(); t2.start(); t3.start(); } } class window extends Thread{ //将其加载在类的动态区,所有线程共享该动态变量 private static int ticket = 100; @Override public void run() { while(true){ if(ticket>0){ System.out.println(getName()+"以后售出第"+ticket+"张票"); ticket--; }else{ break; } } } }
2、实现Runnable接口
步骤:1):定义一个类A实现于java.lang.Runnable接口,留神A类不是线程类.2):在A类中笼罩Runnable接口中的run办法.3):咱们在run办法中编写须要执行的操作(run办法里的,线程执行体).4):在main办法(线程)中,创立线程对象, 并将A实现类做参传给线程结构器,而后通过start()办法启动线程.
生产者与消费者例子(实现Runnable版):
package com.example.gxw.Thread; public class ThreadDemo01 { public static void main(String[] args){ window1 w = new window1(); //尽管有三个线程,然而只有一个窗口类实现的Runnable办法,因为三个线程共用一个window对象,所以主动共用100张票 Thread t1=new Thread(w); Thread t2=new Thread(w); Thread t3=new Thread(w); t1.setName("窗口1"); t2.setName("窗口2"); t3.setName("窗口3"); t1.start(); t2.start(); t3.start(); } } class window1 implements Runnable{ private int ticket = 100; @Override public void run() { while(true){ if(ticket>0){ System.out.println(Thread.currentThread().getName()+"以后售出第"+ticket+"张票"); ticket--; }else{ break; } } } }
3、实现Callable接口
步骤:1):定义一个类A实现于java.util.concurrent.Callable接口(JDK5新增).2):在A类中笼罩Callable接口中的call办法.3):咱们在call办法中编写须要执行的操作.4):在main办法(线程)中: 1、创立实现Callable接口的实现类 2、创立FutureTask的对象 3、将callable接口实现类的对象作为传递到FutureTask的结构器中 4、创立Thread对象,将FutureTask的对象作为参数传递到Thread类的结构器中 5、通过Thread对象的start()办法启动线程. 6、通过FutureTask的对象调用办法get能够获取线程中的call的返回值。
学习例子:
package com.example.gxw.Thread;import java.util.concurrent.Callable;import java.util.concurrent.ExecutionException;import java.util.concurrent.FutureTask;/** * 创立线程的形式三:实现callable接口。---JDK 5.0新增 *是否多线程?否,就一个线程 * * 比runable多一个FutureTask类,用来接管call办法的返回值。 * 实用于须要从线程中接管返回值的模式 * * //callable实现新建线程的步骤: * 1.创立一个实现callable的实现类 * 2.实现call办法,将此线程须要执行的操作申明在call()中 * 3.创立callable实现类的对象 * 4.将callable接口实现类的对象作为传递到FutureTask的结构器中,创立FutureTask的对象 * 5.将FutureTask的对象作为参数传递到Thread类的结构器中,创立Thread对象,并调用start办法启动(通过FutureTask的对象调用办法get获取线程中的call的返回值) * * *///实现callable接口的call办法class NumThread implements Callable{ private int sum=0;// //能够抛出异样 @Override public Object call() throws Exception { for(int i = 0;i<=100;i++){ if(i % 2 == 0){ System.out.println(Thread.currentThread().getName()+":"+i); sum += i; } } return sum; }}public class ThreadNew { public static void main(String[] args){ //new一个实现callable接口的对象 NumThread numThread = new NumThread(); //通过futureTask对象的get办法来接管futureTask的值 FutureTask futureTask = new FutureTask(numThread); Thread t1 = new Thread(futureTask); t1.setName("线程1"); t1.start(); try { //get返回值即为FutureTask结构器参数callable实现类重写的call的返回值 Object sum = futureTask.get(); System.out.println(Thread.currentThread().getName()+":"+sum); } catch (ExecutionException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } }}
4、线程池
java中常常须要用到多线程来解决一些业务,咱们十分不倡议单纯应用继承Thread或者实现Runnable接口的形式来创立线程,那样势必有创立及销毁线程消耗资源、线程上下文切换问题。同时创立过多的线程也可能引发资源耗尽的危险,这个时候引入线程池比拟正当,不便线程工作的治理。
应用线程池的形式:
背景:常常创立和销毁,使用量特地大的资源,比方并发状况下的线程,对性能影响很大。思路:提前创立好多个线程,放入线程池之,应用时间接获取,应用完放回池中。能够防止频繁创立销毁,实现反复利用。相似生存中的公共交通工具。(数据库连接池)益处:进步响应速度(缩小了创立新线程的工夫)升高资源耗费(反复利用线程池中线程,不须要每次都创立)便于线程治理corePoolSize:外围池的大小maximumPoolSize:最大线程数keepAliveTime:线程没有工作时最多放弃多长时间后会终止JDK 5.0 起提供了线程池相干API:ExecutorService 和 Executors。ExecutorService:真正的线程池接口,常见子类ThreadPoolExecutor。void execute(Runnable coommand):执行工作/命令,没有返回值,个别用来执行Runnable。Futuresubmit(Callable task):执行工作,有返回值,个别又来执行Callable。void shutdown():敞开连接池。
线程池代码:
ExecutorService e = Executors.newCachedThreadPool(); ExecutorService e = Executors.newSingleThreadExecutor(); ExecutorService e = Executors.newFixedThreadPool(3); // 第一种是可变大小线程池,依照工作数来调配线程, // 第二种是单线程池,相当于FixedThreadPool(1) // 第三种是固定大小线程池。 // 而后运行 e.execute(new MyRunnableImpl());
5、JDK7新增Fork/Join框架
6、JDK8新增并行流
并行流是jdk8的新个性之一,思维就是将一个程序执行的流变为一个并发的流,通过调用parallel()办法来实现。并行流将一个流分成多个数据块,用不同的线程来解决不同的数据块的流,最初合并每个块数据流的处理结果。并行流默认应用的是公共线程池ForkJoinPool,他的线程数是应用的默认值,依据机器的核数,咱们能够适当调整线程数的大小。线程数的调整通过以下形式来实现:System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "100");
例子:
public class Test4 { private static List<FileInfo> fileList= new ArrayList<FileInfo>(); public static void main(String[] args) { System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "100"); createFileInfo(); long startTime=System.currentTimeMillis(); fileList.parallelStream().forEach(e ->{ try { Thread.sleep(1); } catch (InterruptedException f) { f.printStackTrace(); } }); long endTime=System.currentTimeMillis(); System.out.println("jdk8并行流耗时:"+(endTime-startTime)+"ms"); } private static void createFileInfo(){ for(int i=0;i<30000;i++){ fileList.add(new FileInfo("测试对象" + i)); } }}
四、怎么保障线程平安?
首先咱们先理解下,什么是线程平安?
线程平安问题是指,多个线程对同一个共享数据进行操作时,线程没来得及更新共享数据,从而导致另外线程没失去最新的数据,从而产生线程平安问题。而且线程平安须要听从三概念:1、原子性 即一个操作或者多个操作 要么全副执行并且执行的过程不会被任何因素打断,要么就都不执行。2、可见性 可见性是指当多个线程拜访同一个变量时,一个线程批改了这个变量的值,其余线程可能立刻看失去批改的值。3、有序性 即程序执行的程序依照代码的先后顺序执行。
例如:一人上单人厕所,但没有上锁,这时第二人也进入,就导致难堪的事产生了。
怎么解决呢,有以下几种形式:
1、同步锁(synchronized关键字)
1>、办法加锁
应用同步办法,对办法进行synchronized关键字润饰将同步代码块提取进去成为一个办法,用synchronized关键字润饰此办法。对于runnable接口实现多线程,只须要将同步办法用synchronized润饰而对于继承自Thread形式,须要将同步办法用static和synchronized润饰,因为对象不惟一(锁不惟一)。
2>、同步代码块(须要同步监视器,也就是锁做参)
原理是:当线程开始执行同步代码块前,必须先取得对同步代码块的锁定。并且任何时刻只能有一个线程能够取得对同步监视器的锁定,当同步代码块执行实现后,该线程会开释对该同步监视器的锁定。其中的锁,在非静态方法中可为this,在静态方法中为以后类自身。
同步代码块:
synchronized(Object s){ //须要被同步的代码块}
留神,synchronized能够润饰办法,润饰代码块,然而不能润饰结构器、成员变量等。
总结:
1.同步办法依然波及到同步监视器,只是不须要咱们显示的申明。2.非动态的同步办法,同步监视器是this3、动态的同步办法,同步监视器是以后类自身。继承自Thread.class
2、Lock类
lock: 在java.util.concurrent包内。共有三个实现:1、ReentrantLock2、ReentrantReadWriteLock.ReadLock3、ReentrantReadWriteLock.WriteLock次要目标是和synchronized一样, 两者都是为了解决同步问题,解决资源争端而产生的技术。性能相似但有一些以下区别:lock更灵便,能够自在定义多把锁的加锁解锁程序(synchronized要依照先加的后解程序)提供多种加锁计划:lock 阻塞式, trylock 无阻塞式, lockInterruptily 可打断式, 还有trylock的带超时工夫版本。实质上和监视器锁(即synchronized是一样的)能力越大,责任越大,必须管制好加锁和解锁,否则会导致劫难。和Condition类的联合,性能会更高。
ReentrantLock:
步骤:1.先new一个实例 static ReentrantLock r=new ReentrantLock();2.加锁 r.lock()或r.lockInterruptibly(); (此处也是个不同,后者可被打断。 当a线程lock后,b线程阻塞,此时如果是lockInterruptibly,那么在调用b.interrupt()之后,b线程退出阻塞,并放弃对资源的争抢,进入catch块。 (如果应用后者,必须throw interruptable exception 或catch))3、开释锁 r.unlock() (必须做!何为必须做呢,要放在finally外面。 以避免异样跳出了失常流程,导致劫难。 这里补充一个小知识点,finally是能够信赖的:通过测试,哪怕是产生了OutofMemoryError,finally块中的语句执行也可能失去保障。)
ReentrantReadWriteLock:
可重入读写锁(读写锁的一个实现) ReentrantReadWriteLock lock = new ReentrantReadWriteLock()ReadLock r = lock.readLock();WriteLock w = lock.writeLock();两者都有lock,unlock办法。写写,写读互斥;读读不互斥。能够实现并发读的高效线程平安代码
优先应用程序:
Lock类 > 同步代码块 > 同步办法
总结:Synchronized与lock的异同?
雷同:二者都能够解决线程平安问题不同:synchronized机制在执行完相应的代码逻辑当前,主动的开释同步监视器lock须要手动的启动同步(lock()),同时完结同步也须要手动的实现(unlock())(同时以lock的形式更为灵便)
3、原子类(AtomicInteger、AtomicBoolean……)
首先先理解下什么是原子性:
如果把一个事务可看作是一个程序,它要么残缺的被执行,要么齐全不执行。这种个性就叫原子性
而应用原子类就能够保障原子性的操作,等同于synchronized
Java 的原子类都寄存在并发包 java.util.concurrent.atomic 下
根本类型:
应用原子的形式更新根本类型AtomicInteger:整形原子类AtomicLong:长整型原子类AtomicBoolean:布尔型原子类
数组类型:
应用原子的形式更新数组里的某个元素AtomicIntegerArray:整形数组原子类AtomicLongArray:长整形数组原子类AtomicReferenceArray:援用类型数组原子类
援用类型:
AtomicReference:援用类型原子类AtomicStampedReference:原子更新援用类型里的字段原子类AtomicMarkableReference :原子更新带有标记位的援用类型
对象的属性批改类型:
AtomicIntegerFieldUpdater:原子更新整形字段的更新器AtomicLongFieldUpdater:原子更新长整形字段的更新器AtomicStampedReference:原子更新带有版本号的援用类型。该类将整数值与援用关联起来,可用于解决原子的更新数据和数据的版本号,以及解决应用 CAS 进行原子更新时可能呈现的 ABA 问题。
4、volatile关键字(只有在保障原子性的前提下才能够保障线程平安)
这个尽管是一个关键字,但波及很多,还是想详细描述下这段。
volatile关键字作用:
1)保障了不同线程对这个变量进行操作时的可见性,即一个线程批改了某个变量的值,这新值对其余线程来说是立刻可见的。2)禁止进行指令重排序。
针对作用的可见性,具体解释:
每个线程都有独立的高速缓存内存,在读取共享变量时,为了提高效率,防止频繁去物理内存读取值,都会读取之后存储到高速缓存内存,而后呢,这样就可能会呈现了线程平安问题,所以才有了线程平安的解决形式。那volatile是怎么解决的呢?1、读取形式更改:当共享变量A加上volatile关键字时,这个操作,就会通知所有线程,你们高速缓存区保留的共享变量A,曾经有效了,你们只有去物理内存去读取才能够。2、批改值形式更改:用volatile关键字会强制线程将批改的值立刻写入物理内存。
针对作用的禁止指令重排序,具体解释:
1)当程序执行到volatile变量的读操作或者写操作时,在其后面的操作的更改必定全副曾经进行,且后果曾经对前面的操作可见;在其前面的操作必定还没有进行; 2)在进行指令优化时,不能将在对volatile变量拜访的语句放在其前面执行,也不能把volatile变量前面的语句放到其后面执行。
例如:
因为flag变量为volatile变量,那么在进行指令重排序的过程的时候,不会将语句3放到语句1、语句2后面,也不会讲语句3放到语句4、语句5前面。然而要留神语句1和语句2的程序、语句4和语句5的程序是不作任何保障的。
并且volatile关键字能保障,执行到语句3时,语句1和语句2必然是执行结束了的,且语句1和语句2的执行后果对语句3、语句4、语句5是可见的。
讲到这里,怎么实现线程平安呢?
下面有讲到volatile能够保障可见性和被批改的变量的有序性,那能够实现原子性?
先看上面例子:
public class Test { public volatile int inc = 0; public void increase() { inc++; } public static void main(String[] args) { final Test test = new Test(); for(int i=0;i<10;i++){ new Thread(){ public void run() { for(int j=0;j<1000;j++) test.increase(); }; }.start(); } while(Thread.activeCount()>1) //保障后面的线程都执行完 Thread.yield(); System.out.println(test.inc); }}
大家想一下这段程序的输入后果是多少?兴许有些敌人认为是10000。然而事实上运行它会发现每次运行后果都不统一,都是一个小于10000的数字。
可能有的敌人就会有疑难,不对啊,下面是对变量inc进行自增操作,因为volatile保障了可见性,那么在每个线程中对inc自增完之后,在其余线程中都能看到批改后的值啊,所以有10个线程别离进行了1000次操作,那么最终inc的值应该是1000*10=10000。
这外面就有一个误区了,volatile关键字能保障可见性没有错,然而下面的程序错在没能保障原子性。可见性只能保障每次读取的是最新的值,然而volatile没方法保障对变量的操作的原子性。
首先咱们要晓得自增操作是不具备原子性的,它包含读取变量的原始值、进行加1操作、写入工作内存。那么就是说自增操作的三个子操作可能会宰割开执行,就有可能导致上面这种状况呈现:
如果某个时刻变量inc的值为10,
线程1对变量进行自增操作,线程1先读取了变量inc的原始值,而后线程1被阻塞了;
而后线程2对变量进行自增操作,线程2也去读取变量inc的原始值,因为线程1只是对变量inc进行读取操作,而没有对变量进行批改操作,所以不会导致线程2的工作内存中缓存变量inc的缓存行有效,所以线程2会间接去主存读取inc的值,发现inc的值时10,而后进行加1操作,并把11写入工作内存,最初写入物理内存。
而后线程1接着进行加1操作,因为曾经读取了inc的值,留神此时在线程1的工作内存中inc的值依然为10,所以线程1对inc进行加1操作后inc的值为11,而后将11写入工作内存,最初写入物理内存。
那么两个线程别离进行了一次自增操作后,inc只减少了1。
那是不是解决原子性,就能够实现线程平安了呢?
答案:是的。
有以下几种形式提供原子性,即可实现线程平安:
1、synchronized
public class Test { public int inc = 0; public synchronized void increase() { inc++; } public static void main(String[] args) { final Test test = new Test(); for(int i=0;i<10;i++){ new Thread(){ public void run() { for(int j=0;j<1000;j++) test.increase(); }; }.start(); } while(Thread.activeCount()>1) //保障后面的线程都执行完 Thread.yield(); System.out.println(test.inc); }}
2、采纳Lock
public class Test { public int inc = 0; Lock lock = new ReentrantLock(); public void increase() { lock.lock(); try { inc++; } finally{ lock.unlock(); } } public static void main(String[] args) { final Test test = new Test(); for(int i=0;i<10;i++){ new Thread(){ public void run() { for(int j=0;j<1000;j++) test.increase(); }; }.start(); } while(Thread.activeCount()>1) //保障后面的线程都执行完 Thread.yield(); System.out.println(test.inc); }}
3、采纳原子类AtomicInteger:
public class Test { public AtomicInteger inc = new AtomicInteger(); public void increase() { inc.getAndIncrement(); } public static void main(String[] args) { final Test test = new Test(); for(int i=0;i<10;i++){ new Thread(){ public void run() { for(int j=0;j<1000;j++) test.increase(); }; }.start(); } while(Thread.activeCount()>1) //保障后面的线程都执行完 Thread.yield(); System.out.println(test.inc); }}
在java 1.5的java.util.concurrent.atomic包下提供了一些原子操作类,即对根本数据类型的 自增(加1操作),自减(减1操作)、以及加法操作(加一个数),减法操作(减一个数)进行了封装,保障这些操作是原子性操作。atomic是利用CAS来实现原子性操作的(Compare And Swap),CAS实际上是利用处理器提供的CMPXCHG指令实现的,而处理器执行CMPXCHG指令是一个原子性操作。
五、线程是如何调度的呢?
调度策略:
工夫片:线程的调度采纳工夫片轮转的形式抢占式:高优先级的线程抢占CPUJava的调度办法:1.对于同优先级的线程组成先进先出队列(先到先服务),应用工夫片策略2.对高优先级,应用优先调度的抢占式策略
线程的优先级:
等级:MAX_PRIORITY:10MIN_PRIORITY:1NORM_PRIORITY:5
办法:
getPriority():返回线程优先级setPriority(int newPriority):扭转线程的优先级
留神:高优先级的线程要抢占低优先级的线程的cpu的执行权。不是肯定,仅是从概率上来说的,高优先级的线程更有可能被执行。并不意味着只有高优先级的线程执行完当前,低优先级的线程才执行。
六、线程分类?
1.守护线程(是服务线程,程序运行时在后盾提供的一种通用服务的线程,如垃圾回收线程,异样解决线程)2.用户线程(平时应用的用来解决逻辑的线程)若JVM中都是守护线程,以后JVM将退出。(形象了解,唇亡齿寒)
七、其它
java virtual machine(JVM):java虚拟机内存构造: