实现多线程
进程：是正在运行的程序
- 是系统进行资源分配和调用的独立单位
- 每一个进程都有它自己的内存空间和系统资源
线程：是进程中的单个顺序控制流，是一条执行路径
- 单线程：一个进程如果只有一条执行路径，则称为单线程程序，如：记事本程序
- 多线程：一个进程如果有多条执行路径，则称为多线程程序，如：扫雷程序
多线程的实现方式（一）
方式1：继承Thread类
- 定义一个类Mythread继承Thread类
- 在Mythread类中重写run()方法
- 创建Mythread类的对象
- 启动线程
两个小问题：
- 为什么要重写run()方法？
- 因为run()是用来封装被线程执行的代码
- run()方法和start()方法的区别？
- run()：封装线程执行的代码，直接调用，相当于普通方法的调用
- start()：启动线程；然后由JVM调用此线程的run()方法
设置和获取线程名称
Thread类中设置和获取线程名称的方法
- void setName(String name)：将此线程的名称更改为等于参数name
- String getName()：返回此线程的名称
- 通过构造方法也可以设置线程名称
如何获取main()方所在的线程名称？
- public static Thread currentThread()：返回对当前正在执行的线程对象的引用
//MyThreadDemo
public class MyThreadDemo {
public static void main(String[] args) {
MyThread mt1 = new MyThread();
MyThread mt2 = new MyThread();
mt1.setName("飞机");
mt2.setName("火车");
MyThread mt3 = new MyThread("跑车");
mt1.run();
mt2.run();
mt3.run();
System.out.println("-------");
mt1.start();
mt2.start();
mt3.start();
System.out.println("-------");
/*System.out.println(Thread.currentThread().getName()); //main*/
//run是按顺序执行，start是线程随机的
}
}
//MyThread
public class MyThread extends Thread {
public MyThread() {
}
public MyThread(String name) {
super(name);
}
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(getName() + ":" + i);
}
}
}
线程调度
线程有两种调度模式
- 分时调度模式：所有线程轮流使用CPU的使用权，平均分配每个线程占用CPU的时间片
- 抢占式调度模式：优先让优先级高的线程使用CPU，如果线程的优先级相同，那么会随机选择一个，优先级高的线程获取的CPU时间片相对多一些
Java使用的是抢占式调度模式
假如计算机只有一个CPU，那么CPU在某一个时刻只能执行一条指令，线程只有得到CPU时间片，也就是使用权，才可以执行指令。所以说多线程程序的执行是有随机性，因为谁抢到CPU的使用权是不一定的。
Thread类中设置和获取线程优先级的方法
-
public final int getPriority()：返回此线程的优先级
-
public final void setPriority(int newPriority)：更改此线程的优先级
线程默认优先级是5；线程优先级的范围是：1-10
线程优先级高仅仅表示线程获取的CPU时间片的几率高，但是要在次数比较多，或者多次运行的时候才能看到你想要的效果
线程控制
//sleep测试
//MyThreadDemo类
public class MyThreadDemo {
public static void main(String[] args) {
MyThread mt1 = new MyThread();
MyThread mt2 = new MyThread();
MyThread mt3 = new MyThread();
mt1.setName("曹操");
mt2.setName("刘备");
mt3.setName("孙权");
mt1.start();
mt2.start();
mt3.start();
}
}
//MyThread类
public class MyThread extends Thread {
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(getName() + ":" + i);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
//join测试
//MyThreadDemo2类
public class MyThreadDemo2 {
public static void main(String[] args) {
MyThread2 mt1 = new MyThread2();
MyThread2 mt2 = new MyThread2();
MyThread2 mt3 = new MyThread2();
mt1.setName("康熙");
mt2.setName("四阿哥");
mt3.setName("八阿哥");
mt1.start();
try {
mt1.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
mt2.start();
mt3.start();
}
}
//MyThread2类
public class MyThread2 extends Thread {
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(getName() + ":" + i);
}
}
}
//setDaemon测试
//MyThreadDemo3类
public class MyThreadDemo3 {
public static void main(String[] args) {
MyThread3 mt1 = new MyThread3();
MyThread3 mt2 = new MyThread3();
mt1.setName("张飞");
mt2.setName("关羽");
//设置主线程为刘备
Thread.currentThread().setName("刘备");
//设置守护线程
mt1.setDaemon(true);
mt2.setDaemon(true);
mt1.start();
mt2.start();
for(int i=0;i<10;i++){
System.out.println(Thread.currentThread().getName()+":"+i);
}
}
}
//MyThread3类
public class MyThread3 extends Thread {
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(getName() + ":" + i);
}
}
}
线程生命周期
多线程的实现方式（二）
方式2：实现Runnable接口
- 定义一个类MyRunnable实现Runnable接口
- 在MyRunnable类中重写run()方法
- 创建Runnable类的对象
- 创建Thread类的对象，把Runnable对象作为构造方法的参数
- 启动线程
多线程的实现方案有两种
- 继承Thread类
- 实现Runnable接口
相比继承Thread类，实现Runnable接口的好处
- 避免了Java单继承的局限性
- 适合多个相同程序的代码去处理同一个资源的情况，把线程和程序的代码、数据有效分离，较好的体现了面向对象的设计思想
//MyRunnableDemo类
public class MyRunnableDemo {
public static void main(String[] args) {
MyRunnable mr = new MyRunnable();
Thread t1 = new Thread(mr,"火车");
Thread t2 = new Thread(mr,"飞机");
t1.start();
t2.start();
}
}
//MyRunnable类
public class MyRunnable implements Runnable {
@Override
public void run() {
for (int i = 0; i < 100; i++){
System.out.println(Thread.currentThread().getName()+","+i);
}
}
}
