在之前的章节中,我们都是假设程序中只有一条执行流,程序从main方法的第一条语句逐条执行直到结束。从本节开始,我们讨论并发,在程序中创建线程来启动多条执行流,并发和线程是一个复杂的话题,本节,我们先来讨论Java中线程的一些基本概念。

创建线程
线程表示一条单独的执行流,它有自己的程序执行计数器,有自己的栈。下面,我们通过创建线程来对线程建立一个直观感受,在Java中创建线程有两种方式,一种是继承Thread,另外一种是实现Runnable接口,我们先来看第一种。
继承Thread
Java中java.lang.Thread这个类表示线程,一个类可以继承Thread并重写其run方法来实现一个线程,如下所示:
public class HelloThread extends Thread {
@Override
public void run() {
System.out.println("hello");
}
}
HelloThread这个类继承了Thread,并重写了run方法。run方法的方法签名是固定的,public,没有参数,没有返回值,不能抛出受检异常。run方法类似于单线程程序中的main方法,线程从run方法的第一条语句开始执行直到结束。
定义了这个类不代表代码就会开始执行,线程需要被启动,启动需要先创建一个HelloThread对象,然后调用Thread的start方法,如下所示:
public static void main(String[] args) {
Thread thread = new HelloThread();
thread.start();
}
我们在main方法中创建了一个线程对象,并调用了其start方法,调用start方法后,HelloThread的run方法就会开始执行,屏幕输出:
hello
为什么调用的是start,执行的却是run方法呢?start表示启动该线程,使其成为一条单独的执行流,背后,操作系统会分配线程相关的资源,每个线程会有单独的程序执行计数器和栈,操作系统会把这个线程作为一个独立的个体进行调度,分配时间片让它执行,执行的起点就是run方法。
如果不调用start,而直接调用run方法呢?屏幕的输出并不会发生变化,但并不会启动一条单独的执行流,run方法的代码依然是在main线程中执行的,run方法只是main方法调用的一个普通方法。
怎么确认代码是在哪个线程中执行的呢?Thread有一个静态方法currentThread,返回当前执行的线程对象:
public static native Thread currentThread();
每个Thread都有一个id和name:
public long getId() public final String getName()
这样,我们就可以判断代码是在哪个线程中执行的,我们在HelloThead的run方法中加一些代码:
@Override
public void run() {
System.out.println("thread name: "+ Thread.currentThread().getName());
System.out.println("hello");
}
如果在main方法中通过start方法启动线程,程序输出为:
thread name: Thread-0 hello
如果在main方法中直接调用run方法,程序输出为:
thread name: main hello
调用start后,就有了两条执行流,新的一条执行run方法,旧的一条继续执行main方法,两条执行流并发执行,操作系统负责调度,在单CPU的机器上,同一时刻只能有一个线程在执行,在多CPU的机器上,同一时刻可以有多个线程同时执行,但操作系统给我们屏蔽了这种差异,给程序员的感觉就是多个线程并发执行,但哪条语句先执行哪条后执行是不一定的。当所有线程都执行完毕的时候,程序退出。
实现Runnable接口
通过继承Thread来实现线程虽然比较简单,但我们知道,Java中只支持单继承,每个类最多只能有一个父类,如果类已经有父类了,就不能再继承Thread,这时,可以通过实现java.lang.Runnable接口来实现线程。
Runnable接口的定义很简单,只有一个run方法,如下所示:
public interface Runnable {
public abstract void run();
}
一个类可以实现该接口,并实现run方法,如下所示:
public class HelloRunnable implements Runnable {
@Override
public void run() {
System.out.println("hello");
}
}
仅仅实现Runnable是不够的,要启动线程,还是要创建一个Thread对象,但传递一个Runnable对象,如下所示:
public static void main(String[] args) {
Thread helloThread = new Thread(new HelloRunnable());
helloThread.start();
}
无论是通过继承Thead还是实现Runnable接口来实现线程,启动线程都是调用Thread对象的start方法。
线程的基本属性和方法
id和name
前面我们提到,每个线程都有一个id和name,id是一个递增的整数,每创建一个线程就加一,name的默认值是"Thread-"后跟一个编号,name可以在Thread的构造方法中进行指定,也可以通过setName方法进行设置,给Thread设置一个友好的名字,可以方便调试。
优先级
线程有一个优先级的概念,在Java中,优先级从1到10,默认为5,相关方法是:
public final void setPriority(int newPriority) public final int getPriority()
这个优先级会被映射到操作系统中线程的优先级,不过,因为操作系统各不相同,不一定都是10个优先级,Java中不同的优先级可能会被映射到操作系统中相同的优先级,另外,优先级对操作系统而言更多的是一种建议和提示,而非强制,简单的说,在编程中,不要过于依赖优先级。
状态
线程有一个状态的概念,Thread有一个方法用于获取线程的状态:
public State getState()
返回值类型为Thread.State,它是一个枚举类型,有如下值:
public enum State {
NEW,
RUNNABLE,
BLOCKED,
WAITING,
TIMED_WAITING,
TERMINATED;
}
关于这些状态,我们简单解释下:
Thread还有一个方法,返回线程是否活着:
public final native boolean isAlive()
线程被启动后,run方法运行结束前,返回值都是true。
是否daemo线程
Thread有一个是否daemo线程的属性,相关方法是:
public final void setDaemon(boolean on) public final boolean isDaemon()
前面我们提到,启动线程会启动一条单独的执行流,整个程序只有在所有线程都结束的时候才退出,但daemo线程是例外,当整个程序中剩下的都是daemo线程的时候,程序就会退出。
daemo线程有什么用呢?它一般是其他线程的辅助线程,在它辅助的主线程退出的时候,它就没有存在的意义了。在我们运行一个即使最简单的"hello world"类型的程序时,实际上,Java也会创建多个线程,除了main线程外,至少还有一个负责垃圾回收的线程,这个线程就是daemo线程,在main线程结束的时候,垃圾回收线程也会退出。
sleep方法
Thread有一个静态的sleep方法,调用该方法会让当前线程睡眠指定的时间,单位是毫秒:
public static native void sleep(long millis) throws InterruptedException;
睡眠期间,该线程会让出CPU,但睡眠的时间不一定是确切的给定毫秒数,可能有一定的偏差,偏差与系统定时器和操作系统调度器的准确度和精度有关。
睡眠期间,线程可以被中断,如果被中断,sleep会抛出InterruptedException,关于中断以及中断处理,我们后续章节再介绍。
yield方法
Thread还有一个让出CPU的方法:
public static native void yield();
这也是一个静态方法,调用该方法,是告诉操作系统的调度器,我现在不着急占用CPU,你可以先让其他线程运行。不过,这对调度器也仅仅是建议,调度器如何处理是不一定的,它可能完全忽略该调用。
join方法
在前面HelloThread的例子中,HelloThread没执行完,main线程可能就执行完了,Thread有一个join方法,可以让调用join的线程等待该线程结束,join方法的声明为:
public final void join() throws InterruptedException
在等待线程结束的过程中,这个等待可能被中断,如果被中断,会抛出InterruptedException。
join方法还有一个变体,可以限定等待的最长时间,单位为毫秒,如果为0,表示无期限等待:
public final synchronized void join(long millis) throws InterruptedException
在前面的HelloThread示例中,如果希望main线程在子线程结束后再退出,main方法可以改为:
public static void main(String[] args) throws InterruptedException {
Thread thread = new HelloThread();
thread.start();
thread.join();
}
过时方法
Thread类中还有一些看上去可以控制线程生命周期的方法,如:
public final void stop() public final void suspend() public final void resume()
这些方法因为各种原因已被标记为了过时,我们不应该在程序中使用它们。
共享内存及问题
共享内存
前面我们提到,每个线程表示一条单独的执行流,有自己的程序计数器,有自己的栈,但线程之间可以共享内存,它们可以访问和操作相同的对象。我们看个例子,代码如下:
public class ShareMemoryDemo {
private static int shared = 0;
private static void incrShared(){
shared ++;
}
static class ChildThread extends Thread {
List<String> list;
public ChildThread(List<String> list) {
this.list = list;
}
@Override
public void run() {
incrShared();
list.add(Thread.currentThread().getName());
}
}
public static void main(String[] args) throws InterruptedException {
List<String> list = new ArrayList<String>();
Thread t1 = new ChildThread(list);
Thread t2 = new ChildThread(list);
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println(shared);
System.out.println(list);
}
}
在代码中,定义了一个静态变量shared和静态内部类ChildThread,在main方法中,创建并启动了两个ChildThread对象,传递了相同的list对象,ChildThread的run方法访问了共享的变量shared和list,main方法最后输出了共享的shared和list的值,大部分情况下,会输出期望的值:
[Thread-0, Thread-1]
通过这个例子,我们想强调说明执行流、内存和程序代码之间的关系。
该例中有三条执行流,一条执行main方法,另外两条执行ChildThread的run方法。
当多条执行流可以操作相同的变量时,可能会出现一些意料之外的结果,我们来看下。
竞态条件
所谓竞态条件(race condition)是指,当多个线程访问和操作同一个对象时,最终执行结果与执行时序有关,可能正确也可能不正确,我们看一个例子:
public class CounterThread extends Thread {
private static int counter = 0;
@Override
public void run() {
try {
Thread.sleep((int)(Math.random()*100));
} catch (InterruptedException e) {
}
counter ++;
}
public static void main(String[] args) throws InterruptedException {
int num = 1000;
Thread[] threads = new Thread[num];
for(int i=0; i<num; i++){
threads[i] = new CounterThread();
threads[i].start();
}
for(int i=0; i<num; i++){
threads[i].join();
}
System.out.println(counter);
}
}
这段代码容易理解,有一个共享静态变量counter,初始值为0,在main方法中创建了1000个线程,每个线程就是随机睡一会,然后对counter加1,main线程等待所有线程结束后输出counter的值。
期望的结果是1000,但实际执行,发现每次输出的结果都不一样,一般都不是1000,经常是900多。为什么会这样呢?因为counter++这个操作不是原子操作,它分为三个步骤:
两个线程可能同时执行第一步,取到了相同的counter值,比如都取到了100,第一个线程执行完后counter变为101,而第二个线程执行完后还是101,最终的结果就与期望不符。
怎么解决这个问题呢?有多种方法:
关于这些方法,我们在后续章节再介绍。
内存可见性
多个线程可以共享访问和操作相同的变量,但一个线程对一个共享变量的修改,另一个线程不一定马上就能看到,甚至永远也看不到,这可能有悖直觉,我们来看一个例子。
public class VisibilityDemo {
private static boolean shutdown = false;
static class HelloThread extends Thread {
@Override
public void run() {
while(!shutdown){
// do nothing
}
System.out.println("exit hello");
}
}
public static void main(String[] args) throws InterruptedException {
new HelloThread().start();
Thread.sleep(1000);
shutdown = true;
System.out.println("exit main");
}
}
在这个程序中,有一个共享的boolean变量shutdown,初始为false,HelloThread在shutdown不为true的情况下一直死循环,当shutdown为true时退出并输出"exit hello",main线程启动HelloThread后睡了一会,然后设置shutdown为true,最后输出"exit main"。
期望的结果是两个线程都退出,但实际执行,很可能会发现HelloThread永远都不会退出,也就是说,在HelloThread执行流看来,shutdown永远为false,即使main线程已经更改为了true。
这是怎么回事呢?这就是内存可见性问题。在计算机系统中,除了内存,数据还会被缓存在CPU的寄存器以及各级缓存中,当访问一个变量时,可能直接从寄存器或CPU缓存中获取,而不一定到内存中去取,当修改一个变量时,也可能是先写到缓存中,而稍后才会同步更新到内存中。在单线程的程序中,这一般不是个问题,但在多线程的程序中,尤其是在有多CPU的情况下,这就是个严重的问题。一个线程对内存的修改,另一个线程看不到,一是修改没有及时同步到内存,二是另一个线程根本就没从内存读。
怎么解决这个问题呢?有多种方法:
关于这些方法,我们在后续章节再介绍。
线程的优点及成本
优点
为什么要创建单独的执行流?或者说线程有什么优点呢?至少有以下几点:
成本
关于线程,我们需要知道,它是有成本的。创建线程需要消耗操作系统的资源,操作系统会为每个线程创建必要的数据结构、栈、程序计数器等,创建也需要一定的时间。
此外,线程调度和切换也是有成本的,当有当量可运行线程的时候,操作系统会忙于调度,为一个线程分配一段时间,执行完后,再让另一个线程执行,一个线程被切换出去后,操作系统需要保存它的当前上下文状态到内存,上下文状态包括当前CPU寄存器的值、程序计数器的值等,而一个线程被切换回来后,操作系统需要恢复它原来的上下文状态,整个过程被称为上下文切换,这个切换不仅耗时,而且使CPU中的很多缓存失效,是有成本的。
当然,这些成本是相对而言的,如果线程中实际执行的事情比较多,这些成本是可以接受的,但如果只是执行本节示例中的counter++,那相对成本就太高了。
另外,如果执行的任务都是CPU密集型的,即主要消耗的都是CPU,那创建超过CPU数量的线程就是没有必要的,并不会加快程序的执行。
小结
本节,我们介绍了Java中线程的一些基本概念,包括如何创建线程,线程的一些基本属性和方法,多个线程可以共享内存,但共享内存也有两个重要问题,一个是竞态条件,另一个是内存可见性,最后,我们讨论了线程的一些优点和成本。
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,同时也希望多多支持!
# Java
# 线程
# 一篇文章带你入门Java基本概念
# Java编程基本概念
# java基本教程之多线程基本概念 java多线程教程
# Java新手入门的30个基本概念
# JAVA基本概念详解
# 都是
# 操作系统
# 多个
# 有一个
# 自己的
# 是在
# 都有
# 所示
# 是一个
# 还有一个
# 两条
# 就会
# 来实现
# 是有
# 在等待
# 有多
# 本节
# 的是
# 完后
# 是个
相关文章:
如何在Golang中实现微服务服务拆分_Golang微服务拆分与接口管理方法
建站之星如何优化SEO以实现高效排名?
网站制作外包价格怎么算,招聘网站上写的“外包”是什么意思?
青岛网站建设如何选择本地服务器?
香港服务器网站测试全流程:性能评估、SEO加载与移动适配优化
如何通过云梦建站系统实现SEO快速优化?
如何用狗爹虚拟主机快速搭建网站?
如何快速辨别茅台真假?关键步骤解析
网站制作网站,深圳做网站哪家比较好?
如何通过VPS建站无需域名直接访问?
c++怎么实现高并发下的无锁队列_c++ std::atomic原子变量与CAS操作【详解】
如何通过网站建站时间优化SEO与用户体验?
定制建站模板如何实现SEO优化与智能系统配置?18字教程
单页制作网站有哪些,朋友给我发了一个单页网站,我应该怎么修改才能把他变成自己的呢,请求高手指点迷津?
如何在局域网内绑定自建网站域名?
免费视频制作网站,更新又快又好的免费电影网站?
网站制作大概多少钱一个,做一个平台网站大概多少钱?
微信h5制作网站有哪些,免费微信H5页面制作工具?
微信小程序 五星评分(包括半颗星评分)实例代码
创业网站制作流程,创业网站可靠吗?
如何在Windows环境下新建FTP站点并设置权限?
如何用腾讯建站主机快速创建免费网站?
学校免费自助建站系统:智能生成+拖拽设计+多端适配
如何快速搭建个人网站并优化SEO?
外贸公司网站制作,外贸网站建设一般有哪些步骤?
python的本地网站制作,如何创建本地站点?
建站之星价格显示格式升级,你的预算足够吗?
如何续费美橙建站之星域名及服务?
如何高效完成自助建站业务培训?
深入理解Android中的xmlns:tools属性
建站之星展会模板:智能建站与自助搭建高效解决方案
建站主机解析:虚拟主机配置与服务器选择指南
东莞专业制作网站的公司,东莞大学生网的网址是什么?
如何生成腾讯云建站专用兑换码?
如何快速生成高效建站系统源代码?
湖北网站制作公司有哪些,湖北清能集团官网?
寿县云建站:智能SEO优化与多行业模板快速上线指南
建站org新手必看:2024最新搭建流程与模板选择技巧
企业微网站怎么做,公司网站和公众号有什么区别?
建站与域名管理如何高效结合?
nginx修改上传文件大小限制的方法
官网自助建站系统:SEO优化+多语言支持,快速搭建专业网站
如何在Windows虚拟主机上快速搭建网站?
头像制作网站在线观看,除了站酷,还有哪些比较好的设计网站?
制作企业网站建设方案,怎样建设一个公司网站?
定制建站方案优化指南:企业官网开发与建站费用解析
如何制作新型网站程序文件,新型止水鱼鳞网要拆除吗?
建站主机选哪家性价比最高?
如何解决VPS建站LNMP环境配置常见问题?
如何注册花生壳免费域名并搭建个人网站?
*请认真填写需求信息,我们会在24小时内与您取得联系。