多线程:多线程允许我们可以"同时"执行多段代码。
实际上多线程是并发运行的,即:JVM中的线程调度会为多个线程分配"CPU时间片",并将这些时间片尽可能均匀的分配给线程,当一个线程获取时间片后,该线程的任务代码被CPU执行,其他线程处于等待状态。这种宏观上同时运行而微观上走走停停的现象称为并发。
java中的线程是由Thread的实例表示。而Thread的创建有两种方式:
1)继承Thread并重写run方法
第一种创建线程的方式虽然定义简单,但也存在一些不足:
由于java是单继承的,这经常导致在实际开发中,为了复用一个类的方法,我们需要继承那个类,而自身又希望是一个线程时导致的继承冲突。
继承了线程需要重写run方法来定义该线程执行的任务代码,这就导致了线程与执行的任务有一个必然的耦合关系,不利于线程的重用。
2)实现Runnable接口并重写run方法来单独定义任务
下面示例怎么用匿名内部类完成线程的两种方式创建:
线程提供了一个静态方法:static Thread currentThread()
该方法可以获取运行这个方法的线程
java中所有代码都是靠线程运行的,main方法也不例外。只不过运行main方法的线程不是由我们创建的。
获取线程信息的相关方法:
线程优先级:
对于线程调度的工作,线程不能干涉,即:线程只能被动的等待分配CPU时间片,而不能主动获取。可以通过修改线程优先级来最大程度改善获取CPU时间片的几率,理论上,线程优先级越高的线程获取CPU时间片的次数越多。
线程的优先级有10个等级,分别用整数1-10表示。其中1最低,10最高,5为默认值。
线程提供了一个静态方法:static void sleep(long ms)
该方法会将运行当前方法的线程阻塞指定毫秒。
守护线程----也称为后台线程
默认创建出来的线程都是前台线程,若要设置为后台线程
可以通过线程提供的方法setDaemon来完成。
后台线程使用上与前台线程一样,但是在结束时机上有一点是不同的,即:当一个进程结束时,所有正在运行的后台线程都会强制结束。而进程的结束是当一个进程中所有前台线程都结束时结束。
所以将来开发中可以将一直保持运行的任务,但是可以随着程序一同结束的放在后台线程上运行。
下面示例可以想象为泰坦尼克号中rose(一个前台进程)跳了之后,jack(守护进程)也随之jump
线程提供了一个方法:join
join可以协调线程间同步运行
网页上文字与图片显示案例----文字先显示,等待图片下载完毕然后显示
final Thread download。。。原因:
当一个方法的局部内部类中需要引用该方法的其他局部变量时,该变量必须是final的
在这里main方法的局部内部类show中想引用main方法的其他局部变量download,那么download就必须是final修饰的。JDK1.8之后由于内存问题被重新定义,不在有这个问题,所以就不再需要做上述设定。
多线程并发安全问题:
当多个线程并发访问统一资源时,由于线程切换时机不确定,导致代码未按照设计方式的顺序执行导致的逻辑混乱。严重时可能导致系统瘫痪。
解决多线程并发安全的手段是将"各干各的"变为"排队执行":
当一个方法被synchronized修饰后,那么该方法称为“同步方法”,即:多个线程不能同时进入到方法
内部执行。
在方法上使用synchronized修饰后,上锁的对象就是当前方法所属对象,即:方法中看到的this
为避免过多的拖慢系统处理速度,有效的缩小同步范围可以在保证并发安全的前提下提高并发的效率。
静态方法使用synchronized,那么一定具有同步效果
静态方法上锁的对象是该方法所属类的类对象。实际上JVM在加载一个类的class文件时,会实例化一个Class类型的实例去保存该类的信息(属性,方法等)。所以JVM中每个加载过的类都有且只有一个Class的实例用于表示它这个Class的实例就是该类的类对象。
互斥锁:
将集合或Map转换为线程安全的:
但是要注意:线程安全的集合也不与迭代器遍历该集合的操作互斥。但是迭代器要求遍历的过程中不能通过集合的方法增删元素,否则会抛出异常,所以在多个线程间有这样的操作时,需要自行维护遍历集合与集合元素操作间的互斥关系。
线程池----主要解决两个问题:
1)控制线程数量。因为线程数多了,会导致内存开销大,严重时会导致系统瘫痪,并且由于线程数量多会导致CPU过度切换,拖慢系统响应。
2)重用线程
BlockingQueue是双缓冲队列。
在多线程并发时,若需要使用队列,我们可以使用Queue,但是要解决一个问题就是同步,但同步操作会降低并发对Queue操作的效率。
BlockingQueue内部使用两条队列,可允许两个线程同时向队列一个做存储,一个做取出操作。在保证并发安全的同时提高了队列的存取效率。
创建方式如下:
BlockingQueue queue = new LinkedBlockingQueue();