Java基础:彻底搞懂java多线程

目录
  • 进程与线程
    • 使用多线程的优势
    • 线程的状态
    • 创建线程
    • 线程中断
  • 总结

进程与线程

进程

进程是操作系统结构的基础,是程序在一个数据集合上运行的过程,是系统进行资源分配和调度的基本单位。进程可以被看作程序的实体,同样,它也是程序的容器。

线程

线程是操作系统调度的最小单元,也叫作轻量级进程。在一个进程中可以创建多个线程,这些线程都拥有各自的计数器、堆栈和局部变量等属性。

使用多线程的优势

  • 使用多线程可以减少程序的响应时间

如果某个操作很耗时,或者陷入长时间的等待,此时程序将不会响应鼠标和键盘等的操作,使用多线程后可以把这个耗时的操作分配到一个单独的线程中执行,从而使程序具备了更好的交互性。

  • 与进程相对,线程创建和切换开销更小,同时多线程在数据共享方面效率非常高。
  • 多CPU 或者多核计算机本身就具备执行多线程的能力。

如果使用单个线程,将无法重复利用计算机资源,这会造成资源的巨大浪费。在多CPU计算机中使用多线程能提高CPU的利用率。

  • 使用多线程能简化程序的结构,使程序便于理解和维护。

线程的状态

  • New

新创建状态。线程被创建,还没有调用start方法,在线程运行之前还有一些基础工作要做。

  • Runnable

可运行状态。一旦调用start方法,线程就处于Runnable 状态。一个可运行的线程可能正在运行也可能没有运行,这取决于操作系统给线程提供运行的时间。

  • Blocked

阻塞状态。表示线程被锁阻塞,它暂时不活动。

  • Waiting

等待状态。线程暂时不活动,并且不运行任何代码,这消耗最少资源,直到线程调度器重新激活它。

  • Timed waiting

超时等待状态。和等待不同的是,它是可以在指定的时间自行返回的。

  • Terminated

终止状态。表示当前线程已经执行完毕。导致线程终止有两种情况:(1)run方法执行完毕正常退出;(2)因为一个没有捕获取得异常而终止了run 方法,导致线程进入终止状态。

线程创建后,调用Thead的start方法,开始进入运行状态,当线程执行wait方法后,线程进入等待状态,进入等待状态的线程需要其他线程通知才能返回运行状态。超时等待相当于在等待状态加上了时间限制,如果超过时间限制,则线程返回运行状态。当线程调用到同步方法时,如果线程没有获得锁则进入阻塞状态,当阻塞状态的线程获取到锁时则重新回到运行状态。当线程执行完毕或者遇到意外异常终止时,都会进入终止状态。

创建线程

  • 继承Thread类,重写run()方法
    public class ThreadExample2 extends Thread{
    	public static void main(String[] args) {
    		Thread mThread=new ThreadExample2();
    		mThread.start();
    	}
    	@Override
    	public void run() {
    		 System.out.print("thread excute");
    	}
    }
    

  • 实现Runnable接口,并实现该接口的Run()方法 (推荐)
    public class ThreadExample {
    	public static void main(String[] args) {
          ExRunnable runnable=new ExRunnable();
          Thread mThread=new Thread(runnable);
    	  mThread.start();
    	}
    }
    public class ExRunnable implements Runnable{
    	@Override
    	public void run() {
            System.out.print("thread excute");
    	}
    }
    

  • 实现Callable接口,重写call()方法

Callable接口是属于Executor框架中的功能类。Callable可以在任务接受后提供一个返回值,Runnable无法提供这个功能。

  • Callable中的call()方法可以抛出异常,而Runnable的run()方法不能抛出异常。
  • 运行Callable可以拿到一个Future对象,Future对象表示异步计算的结果,它提供了检查计算是否完成的方法。
  • 由于线程属于异步计算模型,因此无法从别的线程中得到函数的返回值,在这种情况下就可以使用Future来监视目标线程调用call()方法的情况。但调用Future的get()方法以获取结果时,当前线程就会阻塞,直到call()方法返回结果。
public class ThreadExample {
	public static void main(String[] args) {
	  ExCallable mCallable=new ExCallable();
	  ExecutorService mExecutorService=Executors.newSingleThreadExecutor();
	  Future<String> mFuture=mExecutorService.submit(mCallable);
	  try {
		System.out.println(mFuture.get());
	  } catch (Exception e) {
		e.printStackTrace();
	  }
	}
}
public class ExCallable implements Callable<String> {
	@Override
	public String call() throws Exception {
		// TODO Auto-generated method stub
		return "thread excute";
	}
}

线程中断

当线程的run 方法执行完毕,或者在方法中出现没有捕获的异常时,线程将终止。interrupt方法可以用来请求中断线程。当一个线程调用interrupt方法时,线程的中断标识位为true,线程会不时地检测这个中断标识位,以判断线程是否应该被中断。

// 判断线程是否被中断
Thread.currentThread().isInterrupted();

抛出InterruptedException 异常后,两种处理方法:

void task(){
     ....
     try{
        sleep(50)
     }catch(InterruptedException e){
        Thread.currentThread().interrupted();
     }
 }

在catch子句中,调用Thread.currentThread().interrupted()来设置中断状态(因为抛出异常后中断标识位会复位,即重新设置为false),让外界通过Thread.currentThread().isInterrupted() 来决定是否终止还是继续下去。

void task() throw InterrupetedException{
     sleep(50);
  }

不用try来捕获异常,让方法直接抛出,这样调用者可以捕获这个异常。

中断线程Example

public class StopExampleThread {
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		try {
			InterruptedRunnable mRunnable=new InterruptedRunnable();
			Thread thread=new Thread(mRunnable,"threadDemo");
			thread.start();
			TimeUnit.MILLISECONDS.sleep(10);
			thread.interrupt();
		} catch (InterruptedException e) {
			// 抛出InterruptedException后中断标志被清除
			// 再次调用interrupt恢复中断
			Thread.currentThread().interrupt();
		}
	}
	static class InterruptedRunnable implements Runnable{
		int i=0;
		@Override
		public void run() {
			// TODO Auto-generated method stub
			while(!Thread.currentThread().isInterrupted()) {
				i++;
				System.out.println("i="+i);
			}
			System.out.println("stop");
		}
	}

总结

  • 如果一个线程处于阻塞状态,线程在检查中断标识位时,如果发现中断标识位为true,则会在阻塞方法调用处抛出InterruptedException 异常,并且在抛出异常前将线程的中断标识位复位,即重新设置为false。
  • 被中断的线程不一定会终止,中断线程是为了引起线程的注意,被中断的线程可以决定如何去响应中断。如果是比较重要的线程则不会理会中断,而大部分情况则是线程会将中断作为一个终止的请求。

本篇文章就到这里了,希望能给你带来帮助,也希望您能够多多关注我们的更多内容!

(0)

相关推荐

  • Java httpClient连接池支持多线程高并发的实现

    当采用HttpClient httpClient = HttpClients.createDefault() 实例化的时候.会导致Address already in use的异常. 信息: I/O exception (java.net.BindException) caught when processing request to {}->http://**.**.**.** Address already in use: connect 十一月 22, 2018 5:02:13 下午 or

  • Day12基础不牢地动山摇-Java基础

    目录 1.多线程 1.1 多线程的基本概念 1.2 多线程的实现 1.3 继承Thread类实现多线程 1.4 Runnable接口实现多线程 1.5 Thread类和Runnable接口实现多线程的区别 1.6 线程的操作状态 1.7 Callable实现多线程 1.8 线程命名和取得 1.9 线程的休眠 1.10 线程的优先级 1.11 线程的同步与死锁 1.12 死锁 综合案例 1.解决数据错位问题:依靠同步解决 2.解决数据的重复设置和重复取出 面试题:请解释sleep()和wait()

  • 学习java多线程

    目录 介绍 为什么需要多线程 线程状态转换 线程使用方式 继承 Thread 类 实现 Runnable 接口 实现 Callable 接口 同步代码---Runnable接口方式 同步方法--Runnable接口方法 同步方法---继承方法 synchronized锁机制 死锁 Lock锁机制 介绍 程序(program)是为完成特定任务.用某种语言编写的一组指令的集合.即指一段静态的代码,静态对象. 进程(process)是程序的一次执行过程,或是正在运行的一个程序.是一个动态的过程:有它自

  • Java创建多线程的8种方式集合

    目录 1.继承Thread类,重写run()方法 2.实现Runnable接口,重写run() 3.匿名内部类的方式 4.带返回值的线程(实现implements Callable<返回值类型>) 5.定时器(java.util.Timer) 6.线程池的实现(java.util.concurrent.Executor接口) 7.Lambda表达式的实现(parallelStream) 8.Spring实现多线程 1.继承Thread类,重写run()方法 //方式1 package cn.i

  • java课程设计做一个多人聊天室(socket+多线程)

    目录 课设要求 相关知识点 1.服务端能够看到所有在线用户 2.服务端能够强制用户下线 3.客户端能够看到所有在线用户 4.客户端要求能够向某个用户发送消息 5.运用JDBC实现持久化存储用户信息 6.使用JSONObject对象封装数据 7.使用Maven构建管理项目 类图 项目框架 核心代码 1.maven配置文件pom.xml 2.服务器端Server.java 4.客户端注册界面Register.java 5.客户端聊天界面Chat.java 6.用户实体User.java 7.JDBC

  • Java基础:彻底搞懂java多线程

    目录 进程与线程 使用多线程的优势 线程的状态 创建线程 线程中断 总结 进程与线程 进程 进程是操作系统结构的基础,是程序在一个数据集合上运行的过程,是系统进行资源分配和调度的基本单位.进程可以被看作程序的实体,同样,它也是程序的容器. 线程 线程是操作系统调度的最小单元,也叫作轻量级进程.在一个进程中可以创建多个线程,这些线程都拥有各自的计数器.堆栈和局部变量等属性. 使用多线程的优势 使用多线程可以减少程序的响应时间 如果某个操作很耗时,或者陷入长时间的等待,此时程序将不会响应鼠标和键盘等

  • 两个小例子轻松搞懂 java 中递归与尾递归的优化操作

    废话不多说,我们直接上两个最常见的小例子: 一.递归,伪递归,迭代实现n! package com.njbdqn.test02; /** * 递归,伪递归,迭代实现n! */ public class RecursionTest { public static void main(String[] args) { System.out.println(recurse(5)); //递归显示 System.out.println(camouflageRecurse(5, 1)); //伪递归 Sy

  • 一文彻底搞懂Java和JDK的版本命名问题

    Java是面向对象的编程语言,在我们开发Java应用的程序员的专业术语里,Java这个单词其实指的是Java开发工具,也就是JDK(Java Development Kit).所以我们常常在CSDN等各大程序员论坛讨论到安装Java8或者JDK8或者JDK1.8或J2SE8或J2SE1.8或J2SE8或J2SE1.8,其实这3个专业词汇的概念是一样的. 告诉庆哥,你对Java的版本号以及JDK的命名真正清楚嘛?比如: Java8 Java SE 8.0 JDK1.8 -- 知道这些是怎么回事嘛?

  • 一文搞懂Java创建线程的五种方法

    目录 题目描述 解题思路 代码详解 第一种 继承Thread类创建线程 第二种:实现Runnable接口创建线程 第三种:实现Callable接口,通过FutureTask包装器来创建Thread线程 第四种:使用ExecutorService.Callable(或者Runnable).Future实现返回结果的线程 第五种:使用ComletetableFuture类创建异步线程,且是据有返回结果的线程 题目描述 Java创建线程的几种方式 Java使用Thread类代表线程,所有线程对象都必须

  • 一文搞懂Java中的序列化与反序列化

    目录 序列化和反序列化的概念 应用场景 序列化实现的方式 继承Serializable接口,普通序列化 继承Externalizable接口,强制自定义序列化 serialVersionUID的作用 静态变量不会被序列化 使用序列化实现深拷贝 常见序列化协议对比 小结 序列化和反序列化的概念 当我们在Java中创建对象的时候,对象会一直存在,直到程序终止时.但有时候可能存在一种"持久化"场景:我们需要让对象能够在程序不运行的情况下,仍能存在并保存其信息.当程序再次运行时 还可以通过该对

  • 一文搞懂Java并发AQS的共享锁模式

    目录 概述 自定义共享锁例子 核心原理机制 源码解析 成员变量 共享锁获取acquireShared(int) 共享释放releaseShared(int) 概述 这篇文章深入浅出理解Java并发AQS的独占锁模式讲解了AQS的独占锁实现原理,那么本篇文章在阐述AQS另外一个重要模式,共享锁模式,那什么是共享锁呢? 共享锁可以由多个线程同时获取, 比较典型的就是读锁,读操作并不会产生副作用,所以可以允许多个线程同时对数据进行读操作而不会有线程安全问题,jdk中的很多并发工具比如ReadWrite

  • 一篇文章带你搞懂Java线程池实现原理

    目录 1. 为什么要使用线程池 2. 线程池的使用 3. 线程池核心参数 4. 线程池工作原理 5. 线程池源码剖析 5.1 线程池的属性 5.2 线程池状态 5.3 execute源码 5.4 worker源码 5.5 runWorker源码 1. 为什么要使用线程池 使用线程池通常由以下两个原因: 频繁创建销毁线程需要消耗系统资源,使用线程池可以复用线程. 使用线程池可以更容易管理线程,线程池可以动态管理线程个数.具有阻塞队列.定时周期执行任务.环境隔离等. 2. 线程池的使用 /** *

  • 一文搞懂Java中的日期类

    目录 一.日期类 1.1 第一代日期类 1.2 第二代日期类Calendar 1.3 第三代日期类 一.日期类 在程序的开发中我们经常会遇到日期类型的操作,Java对日期类型的操作提供了很好的支持.在最初的版本下,java.lang包中的System.currentTimeMillis();可以获取当前时间与协调时间(UTC)1970年1月1日午夜之间的时间差(以毫秒为单位测量).我们往往通过调用该方法计算某段代码的耗时. public class TestTime { public stati

  • 一文搞懂JAVA 修饰符

    Java语言提供了很多修饰符,主要分为以下两类: 访问修饰符 非访问修饰符 修饰符用来定义类.方法或者变量,通常放在语句的最前端.我们通过下面的例子来说明: public class ClassName { // ... } private boolean myFlag; static final double weeks = 9.5; protected static final int BOXWIDTH = 42; public static void main(String[] argum

  • 一文搞懂JAVA 枚举(enum)

    Java 枚举是一个特殊的类,一般表示一组常量,比如一年的 4 个季节,一个年的 12 个月份,一个星期的 7 天,方向有东南西北等. Java 枚举类使用 enum 关键字来定义,各个常量使用逗号 , 来分割. 例如定义一个颜色的枚举类. enum Color { RED, GREEN, BLUE; } 以上枚举类 Color 颜色常量有 RED, GREEN, BLUE,分别表示红色,绿色,蓝色. 使用实例: enum Color { RED, GREEN, BLUE; } public c

随机推荐