创建线程的方法
方法一:直接使用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 指令的执行地址,是线程私有的。