IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> Java知识库 -> Java 线程的创建与线程状态 -> 正文阅读

[Java知识库]Java 线程的创建与线程状态

Java 线程的创建

Java 线程的创建有四种方式,如下:

  1. 通过继承Thread类,重写run方法
  2. 通过实现Runnable接口,实现run方法
  3. 通过实现Callable接口,实现call方法,然后由线程池启动,Future对象获取线程情况
  4. 通过实现Callable接口,实现call方法,然后由线程池启动,FutureTask对象获取线程情况

1、继承Thread类?

public class MyThreadClass {

    public static class MyThread extends Thread {
        public void run() {
            System.out.println("====== 小弟在银行排队取钱,排队中。。。");
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("====== 小弟排完队,取到了1000块钱");
        }
    }

    public static void main(String[] args) {
        Thread xiaodi = new MyThread();
        System.out.println("====== 小明安排小弟去银行取钱");
        xiaodi.start();
        System.out.println("====== 小明内心:这小弟不靠谱啊,不知道小弟懂不懂怎么取钱,也不知道有没有取到钱");
        /**
         * 1. run方法不是强制要重写的,用户可以不重写
         * 2. 任务处理结果没有告诉主线程
         */
    }
}

2、实现Runnable接口

import static java.lang.Thread.sleep;

public class MyRunnable {

    public static class MyThread implements Runnable{
        @Override
        public void run() {
            System.out.println("====== 小弟在银行排队取钱,排队中。。。");
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("====== 小弟排完队,取到了1000块钱");
        }
    }

    public static void main(String[] args) {
        Thread xiaodi = new Thread(new MyThread());
        System.out.println("====== 小明安排小弟去银行取钱");
        xiaodi.start();
        System.out.println("====== 小明内心:这小弟不靠谱啊,有没有取到钱也不说一声");
        /**
         * 1. 任务处理结果没有告诉主线程
         */
    }
}

3、Callable接口和Future对象

import java.util.concurrent.*;
import static java.lang.Thread.sleep;

public class MyCallable {

    public static class MyThread implements Callable<String>{
        @Override
        public String call() throws Exception {
            System.out.println("====== 小弟在银行排队取钱,排队中。。。");
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("====== 小弟排完队,取到了1000块钱");
            return "大哥,我取到1000块钱了";
        }
    }

    public static void main(String[] args) throws Exception {
        ExecutorService threadPool = Executors.newFixedThreadPool(1);
        System.out.println("====== 小明安排小弟去银行取钱");
        Future future = threadPool.submit(new MyThread());
        System.out.println("====== 小弟发消息回来,说:"+future.get());
        // 关闭线程池
        threadPool.shutdown();
        System.out.println("====== 小明内心:这小弟不错,事事有回应,取到钱了能说一声");
    }
}

4、Callable接口和FutureTask对象

import java.util.concurrent.*;
import static java.lang.Thread.sleep;

public class MyCallable {

    public static class MyTask implements Callable {
        @Override
        public Object call() throws Exception {
            System.out.println("====== 小弟在银行排队取钱,排队中。。。");
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("====== 小弟排完队,取到了1000块钱");
            return "大哥,我取到1000块钱了";
        }
    }

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        ExecutorService threadPool = Executors.newFixedThreadPool(1);
        System.out.println("====== 小明安排小弟去银行取钱");
        FutureTask futureTask = new FutureTask(new MyTask()){
            @Override
            protected void done() {
                System.out.println("====== 小弟取钱回来,把钱放我桌子上了");
                super.done();
            }
        };
        threadPool.submit(futureTask);
        System.out.println("====== 小弟发消息回来,说:"+futureTask.get());
        // 关闭线程池
        threadPool.shutdown();
        System.out.println("====== 小明内心:这小弟不错,事事有闭环,明年让他当话事人");
    }
}

Java 线程状态

Java中线程的状态分为六种,定义在Thread类的State枚举中。

public class Thread implements Runnable {
	...
	public enum State {
		NEW,
		RUNNABLE,
		BLOCKED,
		WAITING,
		TIMED_WAITING,
		TERMINATED;
	}
	...
}

NEW:初始状态,创建一个线程对象时,线程就处于该状态。
RUNNABLE:运行状态,它包含了就绪(READY)和运行中(RUNNING)两种状态。当线程对象创建后,调用该对象的 start() 方法就会进入就绪状态(READY)。该状态的线程位于可运行线程池中,等待被线程调度选中,获取 CPU 的使用权,在获得 CPU 时间片后会变为运行中状态(RUNNING)。
BLOCKED:阻塞状态,表示线程此时被阻塞了。
WAITING:等待状态,进入该状态的线程需要等待其他线程做出一些特定动作(通知或中断)。
TIMED_WAITING:超时等待状态,该状态与 WAITING 的不同点在于它可以指定等待时间,超过等待时间后,停止等待,自行返回。
TERMINATED:终止状态,表示该线程已经执行完。

下图是Java线程状态之间的切换

线程六种状态切换

  Java知识库 最新文章
计算距离春节还有多长时间
系统开发系列 之WebService(spring框架+ma
springBoot+Cache(自定义有效时间配置)
SpringBoot整合mybatis实现增删改查、分页查
spring教程
SpringBoot+Vue实现美食交流网站的设计与实
虚拟机内存结构以及虚拟机中销毁和新建对象
SpringMVC---原理
小李同学: Java如何按多个字段分组
打印票据--java
上一篇文章      下一篇文章      查看所有文章
加:2021-07-29 23:24:06  更:2021-07-29 23:24:56 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/22 23:34:20-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码