java复习-线程常用操作方法

news2024/7/6 20:18:16

线程常用操作方法

线程的主要方法都定义在 Thread类 之中,因此此处就是学习Thread中的方法。

一. 线程的命名与取得

  • 构造方法:public Thread(Runnable target, String name)
  • 设置名字:public final synchronized void setName(String name)
  • 取得名字:public final String getName()

范例1:观察线程的名字

class MyThread implements Runnable{
	@Override
	public void run() {
        // MyThread 代表着 Runnable 子类,是一类资源,并不是线程,因此不能使用this.getName() 并且也没有这个方法
        // 因此要使用 Thread 的类方法,获得当前线程
		System.out.println(Thread.currentThread().getName()); 
	}
}
public class ThreadDemo {
	public static void main(String[] args) throws Exception{
	MyThread mt = new MyThread(); // Runnable 子类对象
		new Thread(mt, "线程A").start();
		new Thread(mt).start(); 
		new Thread(mt, "线程B").start();		
	}
}

结果:

线程A
线程B
Thread-0

总结: 说明开发者设置名字的线程返回名字,未设置名字的线程自动分配名字。主要是通过 static 属性来完成的,在 Thread 类中定义有如下操作

    /* For autonumbering anonymous threads. */
    private static int threadInitNumber;
    private static synchronized int nextThreadNum() {
        return threadInitNumber++;
    }

范例2:观察线程的名字

class MyThread implements Runnable{
	@Override
	public void run() {
        // MyThread 代表着 Runnable 子类,是一类资源,并不是线程,因此不能使用this.getName() 并且也没有这个方法
        // 因此要使用 Thread 的类方法,获得当前线程
		System.out.println(Thread.currentThread().getName()); 
	}
}
public class ThreadDemo {
	public static void main(String[] args) throws Exception{
	MyThread mt = new MyThread(); // Runnable 子类对象
		new Thread(mt, "线程A").start();
		mt.run(); // 对象直接调用 run() 方法
	}
}

结果:

main
线程A

总结:

  • 直接在主方法中调用线程类对象的 run() 方法,得到的名称是 “main”,即——主方法也是一个线程;
  • 在任何的开发之中,主线程可以创建若干个子线程,创建子线程的目的是可以将一些复杂逻辑或者比较耗时的逻辑交由子线程处理;
  • 主线程负责处理整体流程,而子线程负责处理耗时操作。

例如,如下程序会在执行任务一之后,发生轻微卡顿。

public class ThreadDemo {
	public static void main(String[] args){
		System.out.println("1. 执行任务一");
		int temp = 0;
		for (int i = 0; i < Integer.MAX_VALUE; i++) {
			temp += i;
		}
		System.out.println("2. 执行任务二");
		System.out.println("3. 执行任务三");
	}
}

将任务一放在子线程中进行,运行情况明显改善

public class ThreadDemo {
	public static void main(String[] args){
		System.out.println("1. 执行任务一");
		new Thread(()->{ // 子线程负责统计
			int temp = 0;
			for (int i = 0; i < Integer.MAX_VALUE; i++) {
				temp += i;
			}
		});

		System.out.println("2. 执行任务二");
		System.out.println("3. 执行任务三");
	}
}

二. 线程休眠(sleep())

目的:希望某一个线程可以暂缓执行,就可以使用休眠处理。

方法:

  • public static native void sleep(long millis) throws InterruptedException;
  • public static void sleep(long millis, int nanos)throws InterruptedException;

范例:

public class ThreadDemo {
	public static void main(String[] args){
		new Thread(()->{ // 子线程负责统计
			for (int i = 0; i < 10 ; i++) {
				System.out.println(Thread.currentThread().getName() + temp);
				try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}).start();;
	}
}

三. 线程中断(interrupt())

在之前发现线程的休眠里面提供有一个中断异常,实际上就证明线程的休眠是可以被打断的,而这种打断肯定是由其它线程完成的。

方法:

  • 判断线程是否被中断 public boolean isInterrupted()
  • 中断线程 public void interrupt()

范例:

public class ThreadDemo {
	public static void main(String[] args) throws InterruptedException{
		Thread th = new Thread(()->{ 
			System.out.println("休眠中...");
			try {
				Thread.sleep(10000); // 子线程休眠10s
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} 
			System.out.println("休眠结束!");
		});
		
		th.start();
		Thread.sleep(1000);  // 主线程休眠1s后中断子线程
		if (!th.isInterrupted()) { // 判断 th 子线程是否被中断
			th.interrupt();  // 中断 th 子线程
			System.out.println("子线程被主线程所中断。。");
		}
		
		
	}
}

结果:

休眠中...
子线程被主线程所中断。。
java.lang.InterruptedException: sleep interrupted
	at java.base/java.lang.Thread.sleep(Native Method)
	at ThreadDemo.lambda$0(ThreadDemo.java:7)
	at java.base/java.lang.Thread.run(Thread.java:833)
休眠结束!

所有正在执行的线程都是可以被中断的,中断线程必须进行异常的处理。

四. 线程强制执行(join())

定义

强制执行:当满足于某些条件之后,某一个线程对象将可以一直独占资源,一直到该线程的程序执行结束。

正常范例

正常情况下,以主线程和子线程为例,两者都在交替执行

public class ThreadDemo {
	public static void main(String[] args) throws InterruptedException{
		Thread th = new Thread(() -> {
			for(int i = 0; i < 10; i++) {
				try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				System.out.println(Thread.currentThread().getName() + "执行,i = " + i);
			}
			
		}, "正常的子线程");
		
		th.start();
		for(int i = 0; i < 10; i++) {
			Thread.sleep(100);
			System.out.println("正常的主线程,执行,i = " + i);
		}
		
		
	}
}

结果:

正常的子线程执行,i = 0
正常的主线程,执行,i = 0
正常的子线程执行,i = 1
正常的主线程,执行,i = 1
正常的子线程执行,i = 2
正常的主线程,执行,i = 2
正常的主线程,执行,i = 3
正常的子线程执行,i = 3

独占范例

但是如果说现在你希望主线程独占执行。那么就可以利用 Thread 类中的方法:

  • public final void join() throws InterruptedException
    需要注意的是:在进行线程强制执行的时候一定要获取强制执行线程对象之后才可以执行 join()调用。
public class ThreadDemo {
	public static void main(String[] args) throws InterruptedException{
		Thread th = new Thread(() -> {
			for(int i = 0; i < 5; i++) {
				try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				System.out.println(Thread.currentThread().getName() + "执行,i = " + i);
			}
			
		}, "优先的子线程");
		
		th.start();
		for(int i = 0; i < 5; i++) {
			Thread.sleep(100);
			if(i == 1)
				th.join(); // 主线程执行1次后,子线程独占资源,直到执行完毕
			System.out.println("被迫等待的主线程,执行,i = " + i);
		}
		
		
	}
}

结果:

优先的子线程执行,i = 0
被迫等待的主线程,执行,i = 0
优先的子线程执行,i = 1
优先的子线程执行,i = 2
优先的子线程执行,i = 3
优先的子线程执行,i = 4
被迫等待的主线程,执行,i = 1
被迫等待的主线程,执行,i = 2
被迫等待的主线程,执行,i = 3
被迫等待的主线程,执行,i = 4

五. 线程的礼让(yield())

线程的礼让指的是先将资源让出去让别的线程先执行。线程的礼让可以使用 Thread 中提供的方法;

  • public static native void yield(); // 这是一个静态方法
    但与强制执行不同,礼让执行的时候每一次调用 yield() 方法都只会礼让一次当前的资源。

范例:在之前 join() 的基础上,让强占资源的子线程通过 yield() 让出线程

public class ThreadDemo {
	public static void main(String[] args) throws InterruptedException{
		Thread th = new Thread(() -> {
			for(int i = 0; i < 5; i++) {
				try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				System.out.println(Thread.currentThread().getName() + "执行,i = " + i);
				
				// 当执行到第二次时进行一次礼让
				if(i > 1){
					Thread.yield(); 
					System.out.println("------礼让执行------");
				}
			}
			
		}, "优先的子线程");
		
		
		th.start();
		for(int i = 0; i < 5; i++) {
			Thread.sleep(100);
			if(i == 1)
				th.join(); // 主线程执行1次后,子线程独占资源,直到执行完毕
			System.out.println("被迫等待的主线程,执行,i = " + i);
		}
		
		
	}
}

结果:

被迫等待的主线程,执行,i = 0
优先的子线程执行,i = 0
优先的子线程执行,i = 1
优先的子线程执行,i = 2
------礼让执行------
优先的子线程执行,i = 3
------礼让执行------
优先的子线程执行,i = 4
------礼让执行------
被迫等待的主线程,执行,i = 1
被迫等待的主线程,执行,i = 2
被迫等待的主线程,执行,i = 3
被迫等待的主线程,执行,i = 4

思考(关于 join 和 yield)

通过观察结果我们发现,并没有实现预期的效果:

子线程礼让,被迫等待main线程执行。

通过查阅资料后,我们发现了 join()yield() 方法对应于操作系统的细节:
我们知道操作系统对于进程和线程的调度,有五大状态之分:
在这里插入图片描述

而对于上述的两个方法而言:

  • yield() 是将当前线程从运行状态转换到就绪状态,而不能是等待或者阻塞状态。操作系统会从就绪态中的线程重新调度(当然运气好的话,你刚让出来又被调进去,就会出现礼让无效果的情况)
  • join() 方法在线程实例中被调用,当前运行的线程会被堵塞,当前线程变为堵塞态,直到线程实例运行完成。
    因此,对于被子线程的 join()堵塞的main线程,其本身的状态就不在就绪态之中,所以即使子线程使用 yield() 礼让,操作系统也会从就绪态的线程中选择调用,而不会运行处于堵塞态的main线程。

六. 线程优先级(setPriority())

从理论上来讲线程的优先级越高越有可能先执行(越有可能先抢占到资源)。在 Thread 类里面针对于优先级的操作提供有如下的两个处理方法:

  • 设置优先级: public final void setPriority(int new Priority)
  • 获取优先级: public final int getPriority()
    在进行优先级定义的时候都是通过 int 型的数字来完成的,而对于此数字的选择在 Thread 类里面就定义有三个常量:
  • 最高优先级: public static final int MAX PRIORITY;——10
  • 中等优先级: public static final int NORMPRIORITY;——5
  • 最低优先级: public static final int MIN PRIORITY;——1

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1006473.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

解决“您在 /var/spool/mail/root 中有新邮件”问题

一、发现问题 二、解决问题 1、删除邮件 cat /dev/null > /var/spool/mail/root 2、禁止系统启动邮件检查 echo "unset MAILCHECK" >> /etc/profile 三、解决结果

16G FC SFP+ SW光模块应用解析

随着云计算、大数据和物联网等技术的迅猛发展&#xff0c;数据传输速率不断提高。传统的铜缆传输面临带宽瓶颈和信号衰减等问题&#xff0c;而光纤传输凭借其高带宽、低损耗等优势成为了现代通信的主要选择。易天光通信的16G SFP SW 多模光模块作为高性能光纤传输设备&#xff…

SAP HANA 体系结构,LandScape,规模调整:完整教程

目录 一、SAP HANA 体系结构 二、SAP HANA 景观 三、SAP HANA 大小调整 SAP HANA 数据库是以主内存为中心的数据管理平台。 SAP HANA 数据库在 SUSE Linux Enterprises Server 上运行&#xff0c;并基于 C 语言构建。 SAP HANA 数据库可以分发到多台计算机。 SAP HANA 的优…

上海亚商投顾:三大指数小幅下跌 光刻机概念股午后走强

上海亚商投顾前言&#xff1a;无惧大盘涨跌&#xff0c;解密龙虎榜资金&#xff0c;跟踪一线游资和机构资金动向&#xff0c;识别短期热点和强势个股。 一.市场情绪 三大指数昨日小幅调整&#xff0c;创业板指走势较弱。减肥药概念股继续大涨&#xff0c;常山药业2连板&#x…

CDH 集群离线部署、大数据组件安装与扩容详细步骤(cdh-6.3.1)

一、环境准备 1、服务器配置和角色规划 IP 地址主机名硬件配置操作系统安装步骤10.168.168.1cm-server8C16GCentos7新建10.168.168.2agent018C16GCentos7新建10.168.168.3agent028C16GCentos7新建10.168.168.4agent038C16GCentos7新建10.168.168.5agent048C16GCentos7扩容 2…

Harmonic Drive哈默纳科减速机旋转方向和减速比

Harmonic Drive哈默纳科减速机是一款广泛应用于工业生产中的机械设备&#xff0c;通过减速旋转运动来降低机器的转速和输出功率&#xff0c;从而实现精准的调节和控制。哈默纳科减速机的结构紧凑&#xff0c;体积小&#xff0c;重量轻&#xff0c;安装方便&#xff0c;维护简单…

深入了解 FastAPI 鉴权:掌握前后端身份验证的最佳实践

在构建现代化的 Web 应用程序时&#xff0c;用户身份验证和授权是不可或缺的组成部分。FastAPI 提供了多种方法来实现鉴权&#xff0c;以确保只有授权用户可以访问特定的资源或执行特定的操作。本文将介绍 FastAPI 中的鉴权方法&#xff0c;包括基本概念、实践案例和一些提示和…

企业如何转动自己的命运齿轮,实现数字化转型

企业进行数字化转型&#xff0c;需要熟悉数字化转型相关知识&#xff0c;了解众多前辈企业数字化转型成功或失败的案例&#xff0c;从中提炼出数字化转型的关键要点&#xff0c;在数字化转型的浪潮中&#xff0c;破浪前行。 数字化转型关键因素 1、数据 数据是数字化转型的基…

zeppelin安装python(使用pymysql包)

zeppelin安装python&#xff1a; zeppelin的测试环境安装的python的pymysql包 更改zeppelin的python的interpreters&#xff08;注意需要匹配跟我们的python版本相匹配&#xff09; 参考官网链接&#xff1a;https://zeppelin.apache.org/docs/0.10.1/interpreter/python.htm…

开源软件镜像平台-山东大学镜像站

山东大学镜像站 山东大学镜像站是由山东大学&#xff08;青岛&#xff09;网管会镜像站学生运营团队运营的开源镜像站平台&#xff0c;网站平台专门为技术爱好者、工程师、科研人员等开源爱好者提供给丰富的开源镜软件像资源&#xff0c;以及相关的学习和帮助资料&#xff0c;…

简单聊聊G1垃圾回收算法整个流程 --- 理论篇 -- 上

简单聊聊G1垃圾回收算法整个流程 --- 理论篇 -- 上 G1 是什么为什么需要 G1 G1 GC 流程并发标记根对象枚举安全点 位图标记整体流程初始标记阶段并发标记阶段三色标记法SATB(原始快照)SATB 专用写屏障优化SATB 专用写屏障和多线程执行 最终标记存活对象计数收尾工作转移效率总结…

Python实现自主售卖机

1 问题 在python中我们常常使用到条件判断&#xff0c;if语句时常见的条件判断语句之一。那么如何使用if语句实现根据情况自动选择商品进行售卖呢&#xff1f; 2 方法 根据if语句执行时从上往下执行的特点&#xff0c;使用if语句、dict和list来实现整个流程。 代码清单 1 drink…

jd(按关键字搜索商品)API接口

为了进行电商平台 的API开发&#xff0c;首先我们需要做下面几件事情。 1&#xff09;开发者注册一个账号 2&#xff09;然后为每个jd应用注册一个应用程序键&#xff08;App Key) 。 3&#xff09;下载jdAPI的SDK并掌握基本的API基础知识和调用 4&#xff09;利用SDK接口和…

长胜证券:新股配号是怎么配的?

近年来&#xff0c;股票买卖成为了越来越多人的出资选择&#xff0c;而新股的配号过程也成为了社会热议的论题。那么&#xff0c;新股配号是怎么配的呢&#xff1f;本文将从发行方法、配号规矩和影响要素等多个角度分析&#xff0c;为读者解答这一问题。 发行方法 首先要了解的…

运维必备 | ansible 自动化运维工具之变量的定义与调用

各位亲爱的读者&#xff0c;现在公众号更改了推送规则&#xff0c;如果您需要第一时间看到我们推送的好内容。 一定要记得给公众号星标&#xff0c;经常点赞、在看、转发、分享和留下您的评论 &#xff01; 关注回复【学习交流群】加入【安全开发运维】答疑交流群 请朋友们【多…

全球变暖我们在行动

人类在近一个世纪以来大量使用矿物燃料&#xff08;如煤、石油等&#xff09;&#xff0c;排放出大量的二氧化碳等多种温室气体&#xff0c;这些温室气体是导致全球气候变暖的主要原因。 二氧化碳的生态平衡遭到破坏&#xff0c;大气中二氧化碳含量逐年增加&#xff0c;导致地…

国产理想二极管控制器SCT53600,可替代TI的LM74700

SCT53600是一个理想二极管控制器&#xff0c;与外部n通道MOSFET作为一个理想的二极管整流器&#xff0c;低损耗反向极性保护&#xff0c;以取代肖特基二极管。SCT53600在4V到65V的宽电源电压范围内工作。该设备能够承受并保护负供电电压下的负载&#xff0c;并阻止反向电流&…

【自用】深度学习工作站安装ubuntu 18.04 LTS系统

工作站配置&#xff1a; 自己组装的 主板&#xff1a;华硕Z790P&#xff08;PCIE插槽间距大&#xff0c;可以装双显卡&#xff09; CPU&#xff1a;i5 13600KF 内存&#xff1a;32 G 显卡&#xff1a;GTX 2080 Ti &#xff08;魔改版&#xff0c;22G&#xff09; 存储&#xf…

Python 图形化界面基础篇:添加文本框( Entry )到 Tkinter 窗口

Python 图形化界面基础篇&#xff1a;添加文本框&#xff08; Entry &#xff09;到 Tkinter 窗口 引言什么是 Tkinter 文本框&#xff08; Entry &#xff09;&#xff1f;步骤1&#xff1a;导入 Tkinter 模块步骤2&#xff1a;创建 Tkinter 窗口步骤3&#xff1a;创建文本框&…

S7-1200PLC和LED电子看板通信(TCP/IP)

S7-200SMART PLC和LED电子看板通信应用,请查看下面文章链接: SMART 200 PLC UDP通讯应用LED看板_RXXW_Dor的博客-CSDN博客开放式用户通信 (OUC) 库:数据解析:https://rxxw-control.blog.csdn.net/article/details/121424897这篇博客我们主要介绍S7-1200PLC和LED电子看板通…