java对线程之创建线程
创建线程的方法
-
方法一:直接使用Thread
package com.wxit.test01; import lombok.extern.slf4j.Slf4j; /** * @author wj * @date 2022.01.01 14:47 */ @Slf4j(topic = "c.TestCreateThread01") public class TestCreateThread01 { public static void main(String[] args) { //创建线程对象 Thread thread = new Thread("t1") { //执行的方法 @Override public void run() { log.debug("sssss"); } }; //启动线程 thread.start(); log.debug("mian"); } }
-
方法二:使用Runnable结合Thread
- Thread 代表线程
- Runnable 可运行的任务(线程要执行的代码)
代码示例:
package com.wxit.test01; import lombok.extern.slf4j.Slf4j; /** * @author wj * @date 2022.01.01 15:01 */ @Slf4j(topic = "c.TestCreateThread02") public class TestCreateThread02 { public static void main(String[] args) { //创建任务对象 Runnable runnable = new Runnable() { @Override public void run() { log.debug("轻轻的风儿轻轻的吹"); } }; //参数一:任务对象 参数二:线程名称 Thread thread = new Thread(runnable,"t1"); thread.start(); } }
-
方法三:FutureTask 配合 Thread
FutureTask 能够接收 Callable 类型的参数,用来处理有返回结果的情况
代码示例:
package com.wxit.test01; import lombok.extern.slf4j.Slf4j; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; /** * @author wj * @date 2022.01.01 15:06 */ @Slf4j(topic = "c.TestCreateThread03") public class TestCreateThread03 { public static void main(String[] args) throws ExecutionException, InterruptedException { FutureTask<Integer> futureTask = new FutureTask<>(() -> { log.debug("hello"); return 100; }); new Thread(futureTask,"t1").start(); //主线程阻塞,同步等待t1线程执行的结果 Integer result = futureTask.get(); log.debug("得到的结果是:{}",result); } }
线程运行的原理
栈与栈帧
Java Virtual Machine Stacks (Java 虚拟机栈)
我们都知道 JVM 中由堆、栈、方法区所组成,其中栈内存是给谁用的呢?其实就是线程,每个线程启动后,虚拟机就会为其分配一块栈内存。
- 每个栈由多个栈帧(Frame)组成,对应着每次方法调用时所占用的内存
- 每个线程只能有一个活动栈帧,对应着当前正在执行的那个方法
线程上下文切换
因为以下一些原因导致 cpu 不再执行当前的线程,转而执行另一个线程的代码
- 线程的 cpu 时间片用完
- 垃圾回收
- 有更高优先级的线程需要运行
- 线程自己调用了 sleep、yield、wait、join、park、synchronized、lock 等方法
当 Context Switch 发生时,需要由操作系统保存当前线程的状态,并恢复另一个线程的状态,Java 中对应的概念就是程序计数器(Program Counter Register),它的作用是记住下一条 jvm 指令的执行地址,是线程私有的