Java多线程基础学习(一)

news/2024/11/17 10:30:28/

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{#休眠1000msThread.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线程。


http://www.ppmy.cn/news/46205.html

相关文章

《C++高并发服务器笔记——第四章》

计算机网络等相关知识可以去小林coding进行巩固&#xff08;点击前往&#xff09; 《C高并发服务器笔记——第四章》 4.1、网络结构模式1.C/S结构①C/S结构简介②C/S结构优点③C/S结构缺点 2.B/S结构①B/S结构简介②B/S结构优点③B/S结构缺点 4.2和4.3、MAC地址、IP地址、端口…

Django框架介绍及搭建开发环境

介绍 是一个开放源代码的web应用框架&#xff0c;由python编写。 与常规的MVC架构不同&#xff0c;为MTV架构。 MTV Model(模型)&#xff1a;负责业务对象和数据库的关系映射&#xff08;ORM&#xff09;。 Template(视图)&#xff1a;负责把页面展示给用户&#xff08;htm…

看完这篇 HTTPS,和面试官扯皮就没问题了

看完这篇 HTTPS&#xff0c;和面试官扯皮就没问题了 下面我们来一起学习一下 HTTPS &#xff0c;首先问你一个问题&#xff0c;为什么有了 HTTP 之后&#xff0c;还需要有 HTTPS &#xff1f;我突然有个想法&#xff0c;为什么我们面试的时候需要回答标准答案呢&#xff1f;为什…

LAMP及论坛搭建

1.编译安装apache 关闭防火墙&#xff0c;将安装Apache所需软件包传到/opt目录下 systemctl stop firewalld.service setenforce 0[rootlocalhost opt]# ls apr-1.6.2.tar.gz apr-util-1.6.0.tar.gz httpd-2.4.29.tar.bz2安装环境依赖包 yum -y install gcc gcc-c make p…

Python 自然语言处理实用指南:第三部分

原文&#xff1a;Hands-on natural language processing with Python 协议&#xff1a;CC BY-NC-SA 4.0 译者&#xff1a;飞龙 本文来自【ApacheCN 深度学习 译文集】&#xff0c;采用译后编辑&#xff08;MTPE&#xff09;流程来尽可能提升效率。 不要担心自己的形象&#xff…

阿里正式加入ChatGPT战局,“通义千问”上线后表现如何?

ChatGPT发布后&#xff0c;数月间全世界都对AI的能力有了新的认知。 ChatGPT掀起的战局&#xff0c;现在又多了一位选手了&#xff01; 阿里版类ChatGPT突然官宣正式对外开放企业邀测&#xff0c;由达摩院开发&#xff0c;名为“通义千问” 顾名思义&#xff0c;阿里正式加入Ch…

Cisco SD-WAN (Viptela) version 20.11.1 ED - 软件定义广域网

请访问原文链接&#xff1a;https://sysin.org/blog/cisco-sd-wan-20/&#xff0c;查看最新版。原创作品&#xff0c;转载请保留出处。 作者主页&#xff1a;sysin.org 支持 SASE 的架构&#xff0c;其集成了面向多云、安全、统一通信和应用优化的各种功能&#xff0c;可用于轻…

Java语法理论和面经杂疑篇《十. 反射机制》

目录 1. 反射(Reflection)的概念 1.1 反射的出现背景 1.2 反射概述 1.3 Java反射机制研究及应用 1.4 反射相关的主要API 1.5 反射的优缺点 2. 理解Class类并获取Class实例 2.1 理解Class 2.1.1 理论上 2.1.2 内存结构上 2.2 获取Class类的实例(四种方法) 2.3 哪些类…