唐山哪个公司可以建网站,沂水做网站,seo诊断分析工具,百度下载免费安装一、创建线程
Java中创建线程的写法有很多种#xff01;#xff01;#xff01;这里介绍其中5种。
方法1#xff1a;继承Thread类#xff0c;重写run
创建一个类#xff0c;让这个类继承自Thread父类#xff0c;再重写我们的run方法就可以了。 使用Thread类#xff…一、创建线程
Java中创建线程的写法有很多种这里介绍其中5种。
方法1继承Thread类重写run
创建一个类让这个类继承自Thread父类再重写我们的run方法就可以了。 使用Thread类不需要import别的包因为它是再Java.lang下面的。
//写一个类继承自标准库的Thread
class MyThread extends Thread {Overridepublic void run() {System.out.println(hello word!);}
}
public class ThreadDemo1 {public static void main(String[] args) {//创建线程是希望线程成为一个独立的执行流执行一段代码//创建线程是相当于雇了个人帮我们干活Thread t new MyThread(); //这里就不用new标准库的thread的了而是刚才创建的子类t.start(); //线程中的特殊方法启动一个线程}
}
注意 start() 是创建了一个新的线程由新的线程来执行t.run()方法。
这个新的线程就是调用操作系统的API 通过操作系统内核创建新线程的PCB并且把要执行的指令交给这个PCB当PCB被调度到了CPU上执行的时候也就执行到了线程run方法的代码了。
如果只是在main方法中输出hello world你的Java进程主要就是有一个线程调用main方法的线程主线程通过t.start()主线程调用stat()创建出一个新的线程新的线程调用t.run()如果我们run()方法执行完毕这个线程自然销毁了。
方法2实现Runnable接口
//Runnable 作用是描述一个“要执行的任务”,run 方法就是任务的执行细节。
class MyRunnable implements Runnable {Overridepublic void run() {System.out.println(hello thread);}
}
public class ThreadDemo2 {public static void main(String[] args) {//这只是描述了个任务Runnable runnable new MyRunnable();//把任务交给线程来执行Thread t new Thread(runnable);t.start();}
}解耦合。目的就是为了让 线程和任务线程要干的活之间分离开。 未来如果要改代码不用多线程使用多进程、线程池或协程……此时代码改动比较小。
方法3使用匿名内部类继承Thread
//使用匿名内部类来创建线程
public class ThreadDemo3 {public static void main(String[] args) {Thread t new Thread() {Overridepublic void run() {super.run();System.out.println(hello);}};t.start();}
}
其中new Thread() ①创建了一个Thread子类子类没有名字所以才叫做“匿名” ②创建了子类的实例并且让 t 引用指向该实例。
方法4使用匿名内部类实现Runable
public class ThreadDemo4 {public static void main(String[] args) {Thread t new Thread(new Runnable() {Overridepublic void run() {System.out.println(hello);}});t.start();}
}这个写法和方法2本质相同只不过把实现Runable任务交给匿名内部类的语法。 此处是创建了一个类实现Runable同时创建了类的实例并且传给Thread的构造方法。
方法5使用Lambda表达式
此方法是最简单最推荐的方法。
public class ThreadDemo5 {public static void main(String[] args) {Thread t new Thread(() - {System.out.println(helloDemo5);});t.start();}
}把任务用lambda表达式来描述直接把lambda传给Thread构造方法。 lambda就是个匿名函数没有名字的函数用一次就没有了。 () - {}
二、Thread类及常见方法
Thread类是JVM用来管理线程的一个类换句话说每个线程都有一个Thread对象与之相关联。 可以说每个执行流都需要有一个对象来描述类似下图而Thread类的对象就是用来描述一个线程执行流的JVM会将这些Thread对象组织起来用于线程调度线程管理。
1. Thread的常见构造方法 其中 最后两个Thread(String name) 和 Thread(Runnable target, String name) 多了个name参数这个参数是为了方便调试而给线程起了个名字。 线程的默认的名字为 thread-0,1,2之类的。
构造方法的格式如下 Thread t1 new Thread(); Thread t2 new Thread(new MyRunnable()); Thread t3 new Thread(“这是我的名字”); Thread t4 new Thread(new MyRunnable(), “这是我的名字”); 例如
public class ThreadDemo6 {public static void main(String[] args) {Thread t new Thread(new Runnable() {Overridepublic void run() {while (true) {System.out.println(hello);}}},mythread);t.start();}
}
2. Thread的几个常见属性 ID是线程的唯一标识不同线程不会重复 名称是各调试工具用到的 getStat构造方法里起的名字 getStat线程状态Java中线程的状态要比操作系统原生的状态更丰富一些 getPrior线程的优先级可以获取也可以设置但是设置了不管用因为优先级是很多要素影响得到的 isDaem是否守护线程是否“后台线程” 前台线程会阻止进程结束前台线程的工作没做完进程是完不了的 后台线程不会阻止线程结束后台线程没做完进程是可以结束的。 代码里手动创建的线程默认都是前台线程包括main默认也是前台 其他JVM自带的线程都是后台线程。 也可以手动使用setDaemon设置成后台线程是后台线程就是守护线程。 把t设置成 守护/后台线程此时进程的结束与否就和t无关了。 isAlive()是否存活判断当前系统中的这个线程是不是有了。 在用户态应用程序中创建了一个线程Thread t new Thread(); 程序中通过t.start();来调用 在真正调用start之前调用t.isAlive()此时是false,此时内核态操作系统内核里没有这个线程 而调用start后就会让内核创建一个PCB此时这个PCB才表示一个真正的线程此时isAlive是 true。 也可以简单的理解为start/run方法是否允许结束了。 另外如果内核里线程把run执行完了此时线程销毁PCB随之释放。但是Thread t 这个对象还不一定被释放此时isAlive也是false。 【总结】 如果 t.run还没执行isAlive 为 false 如果 t,run 正在执行isAlive 为 true 如果 t.run执行结束isAlive 为 false 通过上述我们可以了解Thread t这个对象比内核里的PCB存在的周期要久。
3. 启动一个线程——start()
之前我们已经看到了如何通过复写 run 方法创建一个线程对象但线程对象被创建出来并不意味着线程就开始运行了。
复写run方法是提供给线程要做的事情的指令清单线程对象可以认为是把李四、王五等新线程叫过来了而调用start()方法就是相当于喊一声“行动起来”线程才真正独立去执行了。
总之run方法是描述了我们要做啥任务而stat才是真正开始任务。 调用start方法才真正在操作系统的底层创建出一个线程
4. 终止一个线程
终止线程的意思是不是让线程立即就停止而是通知线程你应该要停止了但是是否真的停止取决于线程这里的具体写法。终止线程有以下两种方式
使用标志位来控制线程是否要停止
public class ThreadDemo8 {private static boolean flag true;public static void main(String[] args) throws InterruptedException{Thread t new Thread(() - {while (flag) { //当flag为true的时候System.out.println(hello!!);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});t.start();Thread.sleep(3000); //当执行到第三秒的时候把flag变为false结束循环flag false;}
}这个代码之所以能够起到作用修改flagt线程就结束完全取决于t线程内部的代码代码里通过flag控制循环。 因此这里只是告诉让这个线程结束这个线程是否要结束什么时候结束都是线程内部自己代码来决定的。因为是while(flag)所以3秒钟后结束了要是while(true)怎么改都不会结束循环。
此方法的缺点自定义变量这种方式不能及时相应尤其在sleep休眠的时间比较久的时候。
使用Thread自带的标志位 interrupt() 方法来进行判定是否要停止。
这里调用interrupt只是通知终止不是线程一定要乖乖终止 【格式】 while (!Thread.currentThread().isInterrupted()) {} 其中 ① while判定判断条件是true则执行方法体内的循环为false则循环结束 ② Thread.currentThread() 这是Thread类的静态方法通过这个方法可以获取到当前线程。哪个线程调用这个方法就是得到哪个线程的对象引用类似于this ③ isInterrupted() 为true表示被终止为false表示未被终止继续执行 ④ 前面有个 ! 逻辑取反符所以当isInterrupted() 为true时!isInterrupted() 就为false反之则为true。
interrupt 会做两件事 ① 把线程内部的标志位boolean给设置成 true ② 如果线程在进行sleep就会触发异常把sleep给唤醒。
但是sleep在唤醒的时候还会做一件事就是把刚在设置的这个标志位再设置回false。清空了标志位这就导致当sleep的异常被catch完了之后循环继续执行 如下述例子
【例1】线程t忽视了终止请求
public class ThreadDemo9 {public static void main(String[] args) throws InterruptedException {Thread t new Thread(() - {while (!Thread.currentThread().isInterrupted()) {System.out.println(hello thread!);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});t.start();Thread.sleep(3000);t.interrupt(); //3秒后把线程内部的标志位boolean给设置成 true}
} 此时循环会一直执行下去这里就是sleep清空的例子。
【例2】线程t立即响应了终止请求加了break
public class ThreadDemo9 {public static void main(String[] args) throws InterruptedException {Thread t new Thread(() - {while (!Thread.currentThread().isInterrupted()) {System.out.println(hello thread!);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();break;}}});t.start();Thread.sleep(3000);t.interrupt(); //3秒后把线程内部的标志位boolean给设置成 true}
}【例3】稍后进行终止 执行完等了3秒钟代码执行完毕。
public class ThreadDemo9 {public static void main(String[] args) throws InterruptedException {Thread t new Thread(() - {while (!Thread.currentThread().isInterrupted()) {System.out.println(hello thread!);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();//稍后再终止try {Thread.sleep(3000);} catch (InterruptedException ex) {ex.printStackTrace();}break;}}});t.start();Thread.sleep(3000);t.interrupt();}
}【总结】 大前提调用interrupt只是告诉线程你该终止了但是它是不是真的终止这是它自己的事情。 注意其中sleep有个清楚标志位的情况唤醒之后线程终不终止立即还是稍后终止就把选择全交给程序员自己了。
5. 等待一个线程
有时我们需要等待一个线程完成它的工作后才能进行自己的下一步工作这是我们需要一个方法明确等待线程的结束 可理解为等待一个线程结束 线程是一个随机调度的过程等待线程做的事就是再控制两个线程结束的顺序。
【例1】
public class ThreadDemo10 {public static void main(String[] args) {Thread t new Thread(() - {for (int i 0; i 3; i) {System.out.println(hello!!!);}try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}});t.start();System.out.println(join 之前);//此处的join就是让当前的main线程来等待t线程执行结束等待t的run执行完try {t.join();} catch (InterruptedException e) {e.printStackTrace();}System.out.println(join之后);}
} 执行过程 t 调用了start()后t 线程和 main主线程就并发执行分头行动 主线程这里打印了“join之前”同时t线程打印了hello thread 我们的t线程在执行过程中主线程并没有打印join之后而是在join这里等待了一会发生阻塞block等待3s之后t线程执行完了我们的主线程才会执行后面的 “join之后” 主线程等待t线程彻底执行完毕之后才继续往下执行了。 通过输出我们也能看出 t 线程肯定比 main 线程先结束。
【例2】
public class ThreadDemo10 {public static void main(String[] args) {Thread t new Thread(() - {for (int i 0; i 3; i) {System.out.println(hello!!!);}try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}});t.start();try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(join 之前);//此处的join就是让当前的main线程来等待t线程执行结束等待t的run执行完try {t.join();} catch (InterruptedException e) {e.printStackTrace();}System.out.println(join之后);}
}在join前加了一个等待5s钟此时在执行join的时候t 已经结束了所以join不会堵塞就会立即返回。
public void join() 无参版本一直等public void join(long millis) 指定一个超时时间最大等待时间这种是最常见的一直等很容易又问题。
【总结】 线程没结束就等待线程结束了就立即返回 总之可以保证这两个线程的返回顺序。
6. 获取当前线程引用
public static Thread currentThread(); 返回当前线程对象的引用。
调用这个方法不需要实例直接通过类名来调用。 Thread t new Thread();Thread.currentThread();在哪个线程中调用就能获取到哪个线程的实例。
7. 休眠当前线程
是我们比较熟悉的一组方法有一点要记得因为线程的调度是不可控的所以这个方法只能保证实际休眠时间是大于等于参数设置的休眠时间的。 public static void sleep(long millis) throws InterruptedException 休眠当前线程 millis 毫秒 public static void sleep(long millis, int nanos) throws InterruptedException 可以更高精度的休眠 public class ThreadDemo {public static void main(String[] args) throws InterruptedException {System.out.println(System.currentTimeMillis());Thread.sleep(3 * 1000);System.out.println(System.currentTimeMillis());}
}
