方式一:继承Thread类的方式:
-
- 创建一个继承于Thread类的子类
-
- 重写Thread类的run() --> 将此线程执行的操作声明在run()中
-
- 创建Thread类的子类的对象
-
- 通过此对象调用start():①启动当前线程 ② 调用当前线程的run()
说明两个问题:
问题一:我们启动一个线程,必须调用start(),不能调用run()的方式启动线程。否则就成了普通调用方法
问题二:如果再启动一个线程,必须重新创建一个Thread子类的对象,调用此对象的start().
//创建Thread类的匿名子类的方式 线程对象只使用一次
new Thread(){
@Override
public void run() {
for (int i = 0; i < 100; i++) {
if(i % 2 == 0){
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
}
}.start();
//1. 创建一个继承于Thread类的子类
* 例子:遍历100以内的所有的偶数
class MyThread extends Thread {
//2. 重写Thread类的run()
@Override
public void run() {
for (int i = 0; i < 100; i++) {
if(i % 2 == 0){
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
}
}
public class ThreadTest {
public static void main(String[] args) {
//3. 创建Thread类的子类的对象
MyThread t1 = new MyThread();
//4.通过此对象调用start():①启动当前线程 ② 调用当前线程的run()
t1.start();
//问题一:我们不能通过直接调用run()的方式启动线程。
// t1.run();
//问题二:再启动一个线程,遍历100以内的偶数。不可以还让已经start()的线程去执行。会报IllegalThreadStateException
// t1.start();
//我们需要重新创建一个线程的对象
MyThread t2 = new MyThread();
t2.start();
//如下操作仍然是在main线程中执行的。
for (int i = 0; i < 100; i++) {
if(i % 2 == 0){
System.out.println(Thread.currentThread().getName() + ":" + i + "***********main()************");
}
}
}
}
测试Thread中的常用方法
-
- start():启动当前线程;调用当前线程的run()
-
- run(): 通常需要重写Thread类中的此方法,将创建的线程要执行的操作声明在此方法中
-
- currentThread():静态方法,返回执行当前代码的线程
-
- getName():获取当前线程的名字
-
- setName():设置当前线程的名字
-
- yield():释放当前cpu的执行权
- Thread.yield()方法作用是:暂停当前正在执行的线程对象(及放弃当前拥有的cup资源),
并执行其他线程。yield()做的是让当前运行线程回到可运行(就绪)状态,以允许具有相同优先级的其他线程获得运行机会。因此,使用yield()的目的是让相同优先级的线程之间能适当的轮转执行。
但是,实际中无法保证yield()达到让步目的,因为让步的线程还有可能被线程调度程序再次选中。
-
- join():在线程a中调用线程b的join(),此时线程a就进入阻塞状态,直到线程b完全执行完以后,线程a才结束阻塞状态。低优先级的线程也可以获得执行
-
- stop():已过时。当执行此方法时,强制结束当前线程。
-
- sleep(long millitime):让当前线程“睡眠”指定的millitime毫秒。在指定的millitime毫秒时间内,当前线程是阻塞状态。
-
- isAlive():判断当前线程是否存活
线程通信:wait() / notify() / notifyAll() :此三个方法定义在Object类中的。
-
线程的优先级:
-
MAX_PRIORITY:10
-
MIN _PRIORITY:1
-
NORM_PRIORITY:5 -->默认优先级
-
2.如何获取和设置当前线程的优先级:
-
getPriority():获取线程的优先级
-
setPriority(int p):设置线程的优先级
-
说明:高优先级的线程要抢占低优先级线程cpu的执行权。但是只是从概率上讲,高优先级的线程高概率的情况下
-
被执行。并不意味着只有当高优先级的线程执行完以后,低优先级的线程才执行。
-
说明
线程创建时继承父线程的优先级
低优先级只是获得调度的概率低,并非一定是在高优先级线程之后才被调用
class HelloThread extends Thread{
@Override
public void run() {
for (int i = 0; i < 100; i++) {
if(i % 2 == 0){
// try {
// sleep(10);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
System.out.println(Thread.currentThread().getName() + ":" + Thread.currentThread().getPriority() + ":" + i);
}
// if(i % 20 == 0){
// yield();释放当前cpu的执行权
// }
}
}
public HelloThread(String name){
super(name);
}
}
public class ThreadMethodTest {
public static void main(String[] args) {
HelloThread h1 = new HelloThread("Thread:1");//通过构造器给线程命名
// h1.setName("线程一");
//设置分线程的优先级
h1.setPriority(Thread.MAX_PRIORITY);
h1.start();
//给主线程命名
Thread.currentThread().setName("主线程");
Thread.currentThread().setPriority(Thread.MIN_PRIORITY);
for (int i = 0; i < 100; i++) {
if(i % 2 == 0){
System.out.println(Thread.currentThread().getName() + ":" + Thread.currentThread().getPriority() + ":" + i);
}
// if(i == 20){
// try {
// h1.join();
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// }
}
// System.out.println(h1.isAlive());
}
}
wait()和join()区别:
1、存在不同的java包中(最明显的区别)
wait()方法需要在java.lang.Object类中声明;而,join()方法是在java.lang.Thread类中声明。
2、使用目的不同
wait()方法用于线程间通信;而join()方法用于在多个线程之间添加排序,第二个线程需要在第一个线程执行完成后才能开始执行。
3、唤醒线程方面的区别
我们可以通过使用notify()和notifyAll()方法启动一个通过wait()方法进入等待状态的线程。但是我们不能打破join()方法所施加的等待,除非或者中断调用了连接的线程已执行完了。
4、同步上下文(最重要的区别)
wait()方法必须从同步(synchronized)的上下文调用,即同步块或方法,否则会抛出IllegalMonitorStateException异常。
但,在Java中有或没有同步的上下文,我们都可以调用join()方法。
方式二:实现Runnable接口的方式:
-
- 创建一个实现了Runnable接口的类
-
- 实现类去实现Runnable中的抽象方法:run()
-
- 创建实现类的对象
-
- 将此对象作为参数传递到Thread类的构造器中,创建Thread类的对象
-
- 通过Thread类的对象调用start()
package atguigu.java;
/**
*
* 比较创建线程的两种方式。
* 开发中:优先选择:实现Runnable接口的方式
* 原因:1. 实现的方式没有类的单继承性的局限性
* 2. 实现的方式更适合来处理多个线程有共享数据的情况。
*
* 联系:public class Thread implements Runnable
* 相同点:两种方式都需要重写run(),将线程要执行的逻辑声明在run()中。
*
* @author shkstart
* @create 2019-02-13 下午 4:34
*/
//1. 创建一个实现了Runnable接口的类
class MThread implements Runnable{
//2. 实现类去实现Runnable中的抽象方法:run()
@Override
public void run() {
for (int i = 0; i < 100; i++) {
if(i % 2 == 0){
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
}
}
public class ThreadTest1 {
public static void main(String[] args) {
//3. 创建实现类的对象
MThread mThread = new MThread();
//4. 将此对象作为参数传递到Thread类的构造器中,创建Thread类的对象
Thread t1 = new Thread(mThread);
t1.setName("线程1");
//5. 通过Thread类的对象调用start():① 启动线程 ②调用当前线程的run()-->调用了Runnable类型的target的run()
t1.start();
//再启动一个线程,遍历100以内的偶数 不需要在new实现类 MThread 的对象 要再new Thread对象
Thread t2 = new Thread(mThread);
t2.setName("线程2");
t2.start();
}
}
线程的生命周期
●JDK中用Thread.State类定义了线程的几种状态
- 要想实现多线程,必须在主线程中创建新的线程对象。Java语言使用Thread类
及其子类的对象来表示线程,在它的一个完整的生命周期中通常要经历如下的五.
种状态:
➢新建:当一个Thread类 或其子类的对象被声明并创建时,新生的线程对象处于新建
状态
➢就绪:处于新建状态的线程被start()后,将进入线程队列等待CPU时间片,此时它已
具备了运行的条件,只是没分配到CPU资源
➢运行:当就绪的线程被调度并获得CPU资源时,便进入运行状态,run()方法定义了线
程的操作和功能
➢阻塞:在某种特殊情况下,被人为挂起或执行输入输出操作时,让出CPU并临时中
止自己的执行,进入阻塞状态
➢死亡:线程完成了它的全部工作或线程被提前强制性地中止或出现异常导致结束
说明:
1.生命周期关注两个概念:状态、相应的方法。
2.关注:状态a–>状态b:哪些方法执行了(回调方法)
某个方法主动调用:状态a–>状态b
3.阻塞:临时状态,不可以作为最终状态
死亡:最终状态。