Java多线程Thread基础学习
作者:lmrylll 时间:2023-04-17 17:12:21
1. 创建线程
1.1 通过构造函数:public Thread(Runnable target, String name){} 或:public Thread(Runnable target){}
示例:
Thread thread1 = new Thread(new MyThread(), "mythread");
class MyThread extends Thread(){
public void run(){
System.out.println("My First Thread');
}
}
1.2 直接实现Runnable接口:
示例:
Thread thread2 = new Thread(new Runnable{}{
public void run(){
System.out.println("This is my thread.");
}
});
2. 运行线程
thead1.start()
3. sleep
try{
#休眠1000ms
Thread.sleep(1000);
}catch(InterruptedException e){
e.printStackTrace();
}
4. getName() 获取线程名字, getId()获取线程id
System.out.println(Thread.currentThread().getName() + ":"+ Thread.currentThread().getId);
5. 停止线程,
千万不用stop(),stop会立即终止线程。
通过interrupt()中断线程,但是中断并没有停止线程,配合异常来实现:
public class Main {
public static void main(String[] args) throws InterruptedException {
try{
Thread thread1=new Thread(new TheThread(),"thread1");
thread1.start();
Thread.sleep(2000);
thread1.interrupt();
}catch (InterruptedException e){
e.printStackTrace();
}
}
}
class TheThread extends Thread{
public void run() {
super.run();
for (int i = 0; i < 10; i++) {
if(this.interrupted()){
break;
}
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
}
注意,如果在TheThread类里加入catch InterruptException的话,可能会导致interrupt被捕获,而绕过if(this.interrupted())的判断而无法终止线程。
6. 等待和通知
线程等待:当前线程就处于等待状态,直到其他线程调用了notify()方法,线程才会继续执行
public final void wait() throws InterruptedException
线程通知:
public final native void notify()
注意:在notify()方法后,当前线程不会马上释放该对象锁,要等到执行notify()方法的线程将程序执行完,也就是退出同步代码块中。
package wait.notify;
public class ThreadWaitNotifyTest {
final static Object object=new Object();
public static class T1 extends Thread{
public void run(){
System.out.println(System.currentTimeMillis()+": T1 start");
synchronized (object){
try {
System.out.println(System.currentTimeMillis()+": T1 wait");
object.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(System.currentTimeMillis()+": T1 end");
}
}
public static class T2 extends Thread{
public void run(){
System.out.println(System.currentTimeMillis()+": T2 start");
synchronized (object){
System.out.println("T2 synchonized code start.");
object.notify();
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
System.out.println("T2 synchonized code end.");
}
}
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(System.currentTimeMillis()+": T2 end");
}
}
public static void main(String[] args){
Thread thread1=new T1();
Thread thread2=new T2();
thread1.start();
thread2.start();
}
}
输出结果:
7. 线程优先级
高优先级的线程将会获得更多的CPU资源。一共分为10个优先级。
public final void setPriority(int newPriority)
源码分析:
public final void setPriority(int newPriority) {
ThreadGroup g;
checkAccess();
if (newPriority > MAX_PRIORITY || newPriority < MIN_PRIORITY) {
throw new IllegalArgumentException();
}
if((g = getThreadGroup()) != null) {
if (newPriority > g.getMaxPriority()) {
newPriority = g.getMaxPriority();
}
setPriority0(priority = newPriority);
}
}
public final static int MIN_PRIORITY = 1;
public final static int NORM_PRIORITY = 5;
public final static int MAX_PRIORITY = 10;
可见线程最高优先级为10, 最低为1, 默认为5.
当设定的newPriority高于该线程组ThreadGroup的最高Priority时,只能分配该线程组的最高Priority
8. 守护线程
类似守护进程,Java存在两种线程:用户线程和守护线程。它是一种特殊线程,执行的是一种后台服务,当一个系统中不存在非守护线程的时候,守护线程会自己销毁。典型的守护线程:JVM的垃圾回收线程。
public final void setDaemon(boolean on)
示例:
public class Main {
public static void main(String[] args) throws InterruptedException {
TheThread theThread=new TheThread();
theThread.setDaemon(true);//设置守护线程
theThread.start();
Thread.sleep(5000);
System.out.println("全都退出啦");
}
public static class TheThread extends Thread{
public void run(){
int i = 0;
while (true){
i++;
System.out.println(Thread.currentThread().getId()+":"+i);
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
源码分析:
设置线程为用户线程(user thread)或守护线程(daemon thread),当剩余运行的线程均为守护线程时,JVM会退出。
public final void setDaemon(boolean on) {
checkAccess();
if (isAlive()) {
throw new IllegalThreadStateException();
}
daemon = on;
}
其中checkAccesss()方法如下:
public final void checkAccess() {
SecurityManager security = System.getSecurityManager();
if (security != null) {
security.checkAccess(this);
}
}
该方法用于判断当前运行的线程是否有修改此线程的权限。
而public final native boolean isAlive();用于判断该线程是否处于alive状态,即该线程是否已经start,且没有die。
当isAlive的话就会抛出IllegalThreadStateException异常。
所以,设置守护线程的方法,逻辑就是先判断当前线程是否有修改的权限,再判断是否处于alive状态,如果不处于alive状态,则根据boolean变量on的值更改它的状态,即true:设为daemon线程,false:设为user线程。
来源:https://blog.csdn.net/lmrylll/article/details/130181975
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
Android中Json数据读取与创建的方法
![](https://img.aspxhome.com/file/2023/3/138963_0s.png)
Spring缓存注解@Cacheable @CacheEvit @CachePut使用介绍
深入学习Java编程中的字符串的进阶使用
解决mybatis-plus自动配置的mapper.xml与java接口映射问题
![](https://img.aspxhome.com/file/2023/5/58045_0s.gif)
Java xml出现错误 javax.xml.transform.TransformerException: java.lang.NullPointerException
Java线程池Executor用法详解
![](https://img.aspxhome.com/file/2023/2/62812_0s.jpg)
c#高效比对大量图片的实例代码
Java编程实现提取文章中关键字的方法
IntelliJ IDEA 2021.1 推出语音、视频功能,边写代码边聊天(功能超级强大)
![](https://img.aspxhome.com/file/2023/6/125586_0s.jpg)
C# 判断字符串为空的几种办法
实现java简单的线程池
![](https://img.aspxhome.com/file/2023/5/58065_0s.png)
关于Scanner对象的输入结束标记问题
![](https://img.aspxhome.com/file/2023/8/77368_0s.png)
jmeter添加自定函数的实例(jmeter5.3+IntelliJ IDEA)
![](https://img.aspxhome.com/file/2023/2/129242_0s.png)
Python如何使用@property @x.setter及@x.deleter
Java实现json数据处理的常用脚本分享
SpringCloud分布式链路跟踪的方法
![](https://img.aspxhome.com/file/2023/6/59936_0s.png)
Java实现24点小游戏
![](https://img.aspxhome.com/file/2023/6/63336_0s.png)
详解Java8中CompletableFuture类的使用
C#的FileInfo类实现文件操作实例
C#实现计算一个点围绕另一个点旋转指定弧度后坐标值的方法
![](https://img.aspxhome.com/file/2023/5/92935_0s.png)