Java线程小刀牛试
线程简介
现代操作系统调度的最小单元是线程，也叫轻量级进程（Light Weight Process），在一个进程里可以创建多个线程，这些线程都拥有各自的计数器、堆栈和局部变量等属性，并且能够访问共享的内存变量。
java.lang.Thread.State 中定义了 6 种不同的线程状态，在给定的一个时刻，线程只能处于其中的一个状态。
以下是各状态的说明，以及状态间的联系：
开始（New） - 还没有调用 start() 方法的线程处于此状态。
可运行（Runnable） - 已经调用了 start() 方法的线程状态。此状态意味着，线程已经准备好了，一旦被线程调度器分配了 CPU 时间片，就可以运行线程。
阻塞（Blocked） - 阻塞状态。线程阻塞的线程状态等待监视器锁定。处于阻塞状态的线程正在等待监视器锁定，以便在调用 Object.wait() 之后输入同步块/方法或重新输入同步块/方法。
等待（Waiting） - 等待状态。一个线程处于等待状态，是由于执行了 3 个方法中的任意方法：
Object.wait()
Thread.join()
LockSupport.park()
定时等待（Timed waiting） - 等待指定时间的状态。一个线程处于定时等待状态，是由于执行了以下方法中的任意方法：
Thread.sleep(sleeptime)
Object.wait(timeout)
Thread.join(timeout)
LockSupport.parkNanos(timeout)
LockSupport.parkUntil(timeout)
终止(Terminated) - 线程 run() 方法执行结束，或者因异常退出了 run() 方法，则该线程结束生命周期。死亡的线程不可再次复生。
构造线程主要有三种方式
继承 Thread 类
实现 Runnable 接口
实现 Callable 接口
通过继承 Thread 类构造线程的步骤：
定义 Thread 类的子类，并重写该类的 run() 方法，该 run() 方法的方法体就代表了线程要完成的任务。因此把 run() 方法称为执行体。
创建 Thread 子类的实例，即创建了线程对象。
调用线程对象的 start() 方法来启动该线程。
示例：
publicclassThreadDemo02{publicstaticvoidmain(String[]args) {Thread02mt1=newThread02("线程A");//实例化对象Thread02mt2=newThread02("线程B");//实例化对象mt1.start();//调用线程主体mt2.start();//调用线程主体}staticclassThread02extendsThread{privateintticket=5;Thread02(Stringname) {super(name); }@Overridepublicvoidrun() {for(inti=0; i<100; i++) {if(this.ticket>0) {System.out.println(this.getName()+"卖票：ticket ="+ticket--); } } } }}
通过实现 Runnable 接口构造线程的步骤：
定义 Runnable 接口的实现类，并重写该接口的 run() 方法，该 run() 方法的方法体同样是该线程的线程执行体。
创建 Runnable 实现类的实例，并依此实例作为 Thread 的 target 来创建 Thread 对象，该 Thread 对象才是真正的线程对象。
调用线程对象的 start() 方法来启动该线程。
示例：
publicclassRunnableDemo{publicstaticvoidmain(String[]args) {MyThreadt=newMyThread("Runnable 线程");//实例化对象newThread(t).run();//调用线程主体newThread(t).run();//调用线程主体newThread(t).run();//调用线程主体}staticclassMyThreadimplementsRunnable{privateintticket=5;privateStringname;MyThread(Stringname) {this.name=name; }@Overridepublicvoidrun() {for(inti=0; i<100; i++) {if(this.ticket>0) {System.out.println(this.name+"卖票：ticket ="+ticket--); } } } }}
通过实现 Callable 接口构造线程的步骤：
创建 Callable 接口的实现类，并实现 call() 方法，该 call() 方法将作为线程执行体，并且有返回值。
创建 Callable 实现类的实例，使用 FutureTask 类来包装 Callable 对象，该 FutureTask 对象封装了该 Callable 对象的 call() 方法的返回值。
使用 FutureTask 对象作为 Thread 对象的 target 创建并启动新线程。
调用 FutureTask 对象的 get() 方法来获得子线程执行结束后的返回值。
示例：
publicclassCallableAndFutureDemo{publicstaticvoidmain(String[]args) {Callablecallable=()->newRandom().nextInt(100);FutureTaskfuture=newFutureTask<>(callable);newThread(future).start();try{Thread.sleep(1000);//可能做一些事情System.out.println(future.get()); }catch(InterruptedException|ExecutionExceptione) { e.printStackTrace(); } }}
实现 Runnable 接口优于继承 Thread 类，因为实现接口方式更便于扩展类。
实现 Runnable 接口的线程没有返回值；而实现 Callable 接口的线程有返回值。
当一个线程运行时，另一个线程可以直接通过 interrupt() 方法中断其运行状态。
publicclassThreadInterruptDemo{publicstaticvoidmain(String[]args) {MyThreadmt=newMyThread();//实例化Runnable子类对象Threadt=newThread(mt,"线程");//实例化Thread对象t.start();//启动线程try{Thread.sleep(2000);//线程休眠2秒}catch(InterruptedExceptione) {System.out.println("3、休眠被终止"); } t.interrupt();//中断线程执行}staticclassMyThreadimplementsRunnable{@Overridepublicvoidrun() {System.out.println("1、进入run()方法");try{Thread.sleep(10000);//线程休眠10秒System.out.println("2、已经完成了休眠"); }catch(InterruptedExceptione) {System.out.println("3、休眠被终止");return;//返回调用处}System.out.println("4、run()方法正常结束"); } }}
Thread 中的 stop 方法有缺陷，已废弃。
安全地终止线程有两种方法：
中断状态是线程的一个标识位，而中断操作是一种简便的线程间交互方式，而这种交互方式最适合用来取消或停止任务。
还可以利用一个 boolean 变量来控制是否需要停止任务并终止该线程。
publicclassThreadStopDemo03{publicstaticvoidmain(String[]args)throwsException{MyTaskone=newMyTask();ThreadcountThread=newThread(one,"CountThread"); countThread.start();//睡眠1秒，main线程对CountThread进行中断，使CountThread能够感知中断而结束TimeUnit.SECONDS.sleep(1); countThread.interrupt();MyTasktwo=newMyTask(); countThread=newThread(two,"CountThread"); countThread.start();//睡眠1秒，main线程对Runner two进行取消，使CountThread能够感知on为false而结束TimeUnit.SECONDS.sleep(1); two.cancel(); }privatestaticclassMyTaskimplementsRunnable{privatelongi;privatevolatilebooleanon=true;@Overridepublicvoidrun() {while(on&&!Thread.currentThread().isInterrupted()) { i++; }System.out.println("Count i ="+i); }voidcancel() { on=false; } }}
run - 线程的执行实体。
start - 线程的启动方法。
setName、getName - 可以通过 setName()、 getName() 来设置、获取线程名称。
setPriority、getPriority - 在 Java 中，所有线程在运行前都会保持在就绪状态，那么此时，哪个线程优先级高，哪个线程就有可能被先执行。可以通过 setPriority、getPriority 来设置、获取线程优先级。
setDaemon、isDaemon - 可以使用 setDaemon() 方法设置线程为守护线程；可以使用 isDaemon() 方法判断线程是否为守护线程。
isAlive - 可以通过 isAlive 来判断线程是否启动。
interrupt - 当一个线程运行时，另一个线程可以直接通过 interrupt() 方法中断其运行状态。
join - 使用 join() 方法让一个线程强制运行，线程强制运行期间，其他线程无法运行，必须等待此线程完成之后才可以继续执行。
Thread.sleep - 使用 Thread.sleep() 方法即可实现休眠。
Thread.yield - 可以使用 Thread.yield() 方法将一个线程的操作暂时让给其他线程执行。
在 Thread 类中可以通过 setName()、 getName() 来设置、获取线程名称。
publicclassThreadNameDemo{publicstaticvoidmain(String[]args) {MyThreadmt=newMyThread();//实例化Runnable子类对象newThread(mt).start();//系统自动设置线程名称newThread(mt,"线程-A").start();//手工设置线程名称Threadt=newThread(mt);//手工设置线程名称t.setName("线程-B"); t.start(); }staticclassMyThreadimplementsRunnable{@Overridepublicvoidrun() {for(inti=0; i<3; i++) {System.out.println(Thread.currentThread().getName()+"运行，i ="+i);//取得当前线程的名字} } }}
在 Thread 类中可以通过 isAlive() 来判断线程是否启动。
publicclassThreadAliveDemo{publicstaticvoidmain(String[]args) {MyThreadmt=newMyThread();//实例化Runnable子类对象Threadt=newThread(mt,"线程");//实例化Thread对象System.out.println("线程开始执行之前 -->"+t.isAlive());//判断是否启动t.start();//启动线程System.out.println("线程开始执行之后 -->"+t.isAlive());//判断是否启动for(inti=0; i<3; i++) {System.out.println("main运行 -->"+i); }//以下的输出结果不确定System.out.println("代码执行之后 -->"+t.isAlive());//判断是否启动}staticclassMyThreadimplementsRunnable{@Overridepublicvoidrun() {for(inti=0; i<3; i++) {System.out.println(Thread.currentThread().getName()+"运行，i ="+i); } } }}
在 Java 程序中，只要前台有一个线程在运行，则整个 Java 进程就不会消失，所以此时可以设置一个守护线程，这样即使 Java 进程结束了，此守护线程依然会继续执行。可以使用 setDaemon() 方法设置线程为守护线程；可以使用 isDaemon() 方法判断线程是否为守护线程。
publicclassThreadDaemonDemo{publicstaticvoidmain(String[]args) {Threadt=newThread(newMyThread(),"线程"); t.setDaemon(true);//此线程在后台运行System.out.println("线程 t 是否是守护进程："+t.isDaemon()); t.start();//启动线程}staticclassMyThreadimplementsRunnable{@Overridepublicvoidrun() {while(true) {System.out.println(Thread.currentThread().getName()+"在运行。"); } } }}
在 Java 中，所有线程在运行前都会保持在就绪状态，那么此时，哪个线程优先级高，哪个线程就有可能被先执行。
publicclassThreadPriorityDemo{publicstaticvoidmain(String[]args) {System.out.println("主方法的优先级："+Thread.currentThread().getPriority());System.out.println("MAX_PRIORITY ="+Thread.MAX_PRIORITY);System.out.println("NORM_PRIORITY ="+Thread.NORM_PRIORITY);System.out.println("MIN_PRIORITY ="+Thread.MIN_PRIORITY);Threadt1=newThread(newMyThread(),"线程A");//实例化线程对象Threadt2=newThread(newMyThread(),"线程B");//实例化线程对象Threadt3=newThread(newMyThread(),"线程C");//实例化线程对象t1.setPriority(Thread.MIN_PRIORITY);//优先级最低t2.setPriority(Thread.MAX_PRIORITY);//优先级最低t3.setPriority(Thread.NORM_PRIORITY);//优先级最低t1.start();//启动线程t2.start();//启动线程t3.start();//启动线程}staticclassMyThreadimplementsRunnable{@Overridepublicvoidrun() {for(inti=0; i<5; i++) {try{Thread.sleep(500);//线程休眠}catch(InterruptedExceptione) { e.printStackTrace(); }//取得当前线程的名字Stringout=Thread.currentThread().getName()+"，优先级："+Thread.currentThread().getPriority()+"，运行：i ="+i;System.out.println(out); } } }}
wait、notify、notifyAll 是 Object 类中的方法。
wait - 线程自动释放其占有的对象锁，并等待 notify。
notify - 唤醒一个正在 wait 当前对象锁的线程，并让它拿到对象锁。
notifyAll - 唤醒所有正在 wait 前对象锁的线程。
生产者、消费者示例：
publicclassThreadWaitNotifyDemo02{privatestaticfinalintQUEUE_SIZE=10;privatestaticfinalPriorityQueuequeue=newPriorityQueue<>(QUEUE_SIZE);publicstaticvoidmain(String[]args) {newProducer("生产者A").start();newProducer("生产者B").start();newConsumer("消费者A").start();newConsumer("消费者B").start(); }staticclassConsumerextendsThread{Consumer(Stringname) {super(name); }@Overridepublicvoidrun() {while(true) {synchronized(queue) {while(queue.size()==0) {try{System.out.println("队列空，等待数据"); queue.wait(); }catch(InterruptedExceptione) { e.printStackTrace(); queue.notifyAll(); } } queue.poll();//每次移走队首元素queue.notifyAll();try{Thread.sleep(500); }catch(InterruptedExceptione) { e.printStackTrace(); }System.out.println(Thread.currentThread().getName()+"从队列取走一个元素，队列当前有："+queue.size()+"个元素"); } } } }staticclassProducerextendsThread{Producer(Stringname) {super(name); }@Overridepublicvoidrun() {while(true) {synchronized(queue) {while(queue.size()==QUEUE_SIZE) {try{System.out.println("队列满，等待有空余空间"); queue.wait(); }catch(InterruptedExceptione) { e.printStackTrace(); queue.notifyAll(); } } queue.offer(1);//每次插入一个元素queue.notifyAll();try{Thread.sleep(500); }catch(InterruptedExceptione) { e.printStackTrace(); }System.out.println(Thread.currentThread().getName()+"向队列取中插入一个元素，队列当前有："+queue.size()+"个元素"); } } } }}
在线程操作中，可以使用 Thread.yield() 方法将一个线程的操作暂时让给其他线程执行。
publicclassThreadYieldDemo{publicstaticvoidmain(String[]args) {MyThreadt=newMyThread();newThread(t,"线程A").start();newThread(t,"线程B").start(); }staticclassMyThreadimplementsRunnable{@Overridepublicvoidrun() {for(inti=0; i<5; i++) {try{Thread.sleep(1000); }catch(Exceptione) { e.printStackTrace(); }System.out.println(Thread.currentThread().getName()+"运行，i ="+i);if(i==2) {System.out.print("线程礼让：");Thread.yield(); } } } }}
在线程操作中，可以使用 join() 方法让一个线程强制运行，线程强制运行期间，其他线程无法运行，必须等待此线程完成之后才可以继续执行。
publicclassThreadJoinDemo{publicstaticvoidmain(String[]args) {MyThreadmt=newMyThread();//实例化Runnable子类对象Threadt=newThread(mt,"mythread");//实例化Thread对象t.start();//启动线程for(inti=0; i<50; i++) {if(i>10) {try{ t.join();//线程强制运行}catch(InterruptedExceptione) { e.printStackTrace(); } }System.out.println("Main 线程运行 -->"+i); } }staticclassMyThreadimplementsRunnable{@Overridepublicvoidrun() {for(inti=0; i<50; i++) {System.out.println(Thread.currentThread().getName()+"运行，i ="+i);//取得当前线程的名字} } }}
直接使用 Thread.sleep() 方法即可实现休眠。
publicclassThreadSleepDemo{publicstaticvoidmain(String[]args) {newThread(newMyThread("线程A",1000)).start();newThread(newMyThread("线程A",2000)).start();newThread(newMyThread("线程A",3000)).start(); }staticclassMyThreadimplementsRunnable{privateStringname;privateinttime;privateMyThread(Stringname,inttime) {this.name=name;//设置线程名称this.time=time;//设置休眠时间}@Overridepublicvoidrun() {try{Thread.sleep(this.time);//休眠指定的时间}catch(InterruptedExceptione) { e.printStackTrace(); }System.out.println(this.name+"线程，休眠"+this.time+"毫秒。"); } }}
ThreadLocal，很多地方叫做线程本地变量，也有些地方叫做线程本地存储，其实意思差不多。可能很多朋友都知道 ThreadLocal 为变量在每个线程中都创建了一个副本，那么每个线程可以访问自己内部的副本变量。
ThreadLocal 的主要方法：
publicclassThreadLocal {publicTget() {}publicvoidremove() {}publicvoidset(Tvalue) {}publicstaticThreadLocalwithInitial(Suppliersupplier) {}}
get()方法是用来获取 ThreadLocal 在当前线程中保存的变量副本。
set()用来设置当前线程中变量的副本。
remove()用来移除当前线程中变量的副本。
initialValue()是一个 protected 方法，一般是用来在使用时进行重写的，它是一个延迟加载方法，下面会详细说明。
get 源码
publicTget() {Threadt=Thread.currentThread();ThreadLocalMapmap=getMap(t);if(map!=null) {ThreadLocalMap.Entrye=map.getEntry(this);if(e!=null) {@SuppressWarnings("unchecked")Tresult=(T)e.value;returnresult; } }returnsetInitialValue();}
取得当前线程。
通过 getMap() 方法获取 ThreadLocalMap。
成功，返回 value；失败，返回 setInitialValue()。
ThreadLocalMap 源码
ThreadLocalMap 是 ThreadLocal 的一个内部类。
ThreadLocalMap 的 Entry 继承了 WeakReference，并且使用 ThreadLocal 作为键值。
privateTsetInitialValue() {Tvalue=initialValue();Threadt=Thread.currentThread();ThreadLocalMapmap=getMap(t);if(map!=null) map.set(this, value);elsecreateMap(t, value);returnvalue;}
如果 map 不为空，就设置键值对；为空，再创建 Map，看一下 createMap 的实现：
voidcreateMap(Threadt,TfirstValue) { t.threadLocals=newThreadLocalMap(this, firstValue);}
至此，可能大部分朋友已经明白了 ThreadLocal 是如何为每个线程创建变量的副本的：
在每个线程 Thread 内部有一个 ThreadLocal.ThreadLocalMap 类型的成员变量 threadLocals，这个 threadLocals 就是用来存储实际的变量副本的，键值为当前 ThreadLocal 变量，value 为变量副本（即 T 类型的变量）。
在 Thread 里面，threadLocals 为空，当通过 ThreadLocal 变量调用 get()方法或者 set()方法，就会对 Thread 类中的 threadLocals 进行初始化，并且以当前 ThreadLocal 变量为键值，以 ThreadLocal 要保存的副本变量为 value，存到 threadLocals。
在当前线程里面，如果要使用副本变量，就可以通过 get 方法在 threadLocals 里面查找。
ThreadLocal 最常见的应用场景为用于解决数据库连接、Session 管理等问题。
示例 - 数据库连接
privatestaticThreadLocalconnectionHolder=newThreadLocal() {publicConnectioninitialValue() {returnDriverManager.getConnection(DB_URL);}};publicstaticConnectiongetConnection() {returnconnectionHolder.get();}
示例 - Session 管理
privatestaticfinalThreadLocalthreadSession=newThreadLocal();publicstaticSessiongetSession() throwsInfrastructureException{Sessions=(Session) threadSession.get();try{if(s==null) { s=getSessionFactory().openSession(); threadSession.set(s); } }catch(HibernateExceptionex) {thrownewInfrastructureException(ex); }returns;}
管道输入/输出流和普通的文件输入/输出流或者网络输入/输出流不同之处在于，它主要用于线程之间的数据传输，而传输的媒介为内存。 管道输入/输出流主要包括了如下 4 种具体实现：PipedOutputStream、PipedInputStream、PipedReader 和 PipedWriter，前两种面向字节，而后两种面向字符。
publicclassPiped{publicstaticvoidmain(String[]args)throwsException{PipedWriterout=newPipedWriter();PipedReaderin=newPipedReader();//将输出流和输入流进行连接，否则在使用时会抛出IOExceptionout.connect(in);ThreadprintThread=newThread(newPrint(in),"PrintThread"); printThread.start();intreceive=0;try{while((receive=System.in.read())!=-1) { out.write(receive); } }finally{ out.close(); } }staticclassPrintimplementsRunnable{privatePipedReaderin;Print(PipedReaderin) {this.in=in; }publicvoidrun() {intreceive=0;try{while((receive=in.read())!=-1) {System.out.print((char) receive); } }catch(IOExceptione) { e.printStackTrace(); } } }}
start() 和 run() 有什么区别？可以直接调用 Thread 类的 run() 方法么？
run() 方法是线程的执行体。
start() 方法会启动线程，然后 JVM 会让这个线程去执行 run() 方法。
可以直接调用 Thread 类的 run() 方法么？
可以。但是如果直接调用 Thread 的 run()方法，它的行为就会和普通的方法一样。
为了在新的线程中执行我们的代码，必须使用 Thread.start()方法。
sleep()、yield()、join() 方法有什么区别？为什么 sleep()和 yield()方法是静态的？
yield()
yield() 方法可以让当前正在执行的线程暂停，但它不会阻塞该线程，它只是将该线程从 Running 状态转入 Runnable 状态。
当某个线程调用了 yield() 方法暂停之后，只有优先级与当前线程相同，或者优先级比当前线程更高的处于就绪状态的线程才会获得执行的机会。
sleep()
sleep() 方法需要指定等待的时间，它可以让当前正在执行的线程在指定的时间内暂停执行，进入 Blocked 状态。
该方法既可以让其他同优先级或者高优先级的线程得到执行的机会，也可以让低优先级的线程得到执行机会。
但是， sleep() 方法不会释放“锁标志”，也就是说如果有 synchronized 同步块，其他线程仍然不能访问共享数据。
join()
join() 方法会使当前线程转入 Blocked 状态，等待调用 join() 方法的线程结束后才能继续执行。
参考阅读：Java 线程中 yield 与 join 方法的区别 参考阅读：sleep()，wait()，yield()和 join()方法的区别
Thread 类的 sleep() 和 yield() 方法将处理 Running 状态的线程。所以在其他处于非 Running 状态的线程上执行这两个方法是没有意义的。这就是为什么这些方法是静态的。它们可以在当前正在执行的线程中工作，并避免程序员错误的认为可以在其他非运行线程调用这些方法。
Java 的线程优先级如何控制？高优先级的 Java 线程一定先执行吗？
Java 中的线程优先级如何控制
Java 中的线程优先级的范围是 [1,10]，一般来说，高优先级的线程在运行时会具有优先权。可以通过 thread.setPriority(Thread.MAX_PRIORITY) 的方式设置，默认优先级为 5。
高优先级的 Java 线程一定先执行吗
即使设置了线程的优先级，也无法保证高优先级的线程一定先执行。
原因：这是因为线程优先级依赖于操作系统的支持，然而，不同的操作系统支持的线程优先级并不相同，不能很好的和 Java 中线程优先级一一对应。
结论：Java 线程优先级控制并不可靠。
什么是守护线程
守护线程（Daemon Thread）是在后台执行并且不会阻止 JVM 终止的线程。
与守护线程（Daemon Thread）相反的，叫用户线程（User Thread），也就是非守护线程。
为什么要用守护线程
守护线程的优先级比较低，用于为系统中的其它对象和线程提供服务。典型的应用就是垃圾回收器。
如何创建守护线程
使用 thread.setDaemon(true) 可以设置 thread 线程为守护线程。
注意点：
正在运行的用户线程无法设置为守护线程，所以 thread.setDaemon(true) 必须在 thread.start() 之前设置，否则会抛出 llegalThreadStateException 异常；
一个守护线程创建的子线程依然是守护线程。
不要认为所有的应用都可以分配给 Daemon 来进行服务，比如读写操作或者计算逻辑。
参考阅读：Java 中守护线程的总结
为什么线程通信的方法 wait(), notify()和 notifyAll()被定义在 Object 类里？
Java 的每个对象中都有一个锁(monitor，也可以成为监视器) 并且 wait()，notify()等方法用于等待对象的锁或者通知其他线程对象的监视器可用。在 Java 的线程中并没有可供任何对象使用的锁和同步器。这就是为什么这些方法是 Object 类的一部分，这样 Java 的每一个类都有用于线程间通信的基本方法
为什么 wait(), notify()和 notifyAll()必须在同步方法或者同步块中被调用？
当一个线程需要调用对象的 wait()方法的时候，这个线程必须拥有该对象的锁，接着它就会释放这个对象锁并进入等待状态直到其他线程调用这个对象上的 notify()方法。同样的，当一个线程需要调用对象的 notify()方法时，它会释放这个对象的锁，以便其他在等待的线程就可以得到这个对象锁。由于所有的这些方法都需要线程持有对象的锁，这样就只能通过同步来实现，所以他们只能在同步方法或者同步块中被调用。
免费Java资料需要自己领取，涵盖了Java、Redis、MongoDB、MySQL、Zookeeper、Spring Cloud、Dubbo/Kafka、Hadoop、Hbase、Flink等高并发分布式、大数据、机器学习等技术。
