首页 > 代码库 > java基础(3)-多线程(1)
java基础(3)-多线程(1)
java多线程
进程与线程
进程:指一个正在执行的应用程序。每个进程执行都有一个执行顺序,该顺序称为一个执行路径或一个控制单元(进程是资源分配的最小单位)。一个进程包含1~n个线程
线程:指进程中某个单一顺序的控制流。线程控制着进程的执行(线程是CPU调度的最小单位)
多进程:指操作系统能同时运行多个任务(程序)
多线程:指在同一程序中有多个顺序流在执行
实现java多线程
在java中要实现多线程,有两种方式,一种是继承Thread类,一种是实现Runable接口
方式一:继承Thread类并复写run方法
步骤:
- 自定义类继承Thread类
- 在自定义类中复写Thread类中的run()方法(目的:将自定义代码存储在run方法中,让线程运行)
- 创建类对象
- 调用线程start方法(方法有两作用:启动线程,调用run方法
例1:
//自定义Demo类继承Thread类 class Demo extends Thread{ //复写run()方法 public void run(){ for(int i=1;i<20;i++){ System.out.println("Demo run"+"--"+i); } } } public class ThreadDemo{ public static void main(String[] args){ //创建线程Demo的线程对象 Demo d = new Demo(); //启动线程并执行该线程的run()方法 //若是d.run()仅仅是对象调用run方法,而线程创建了并未运行 d.start(); for(int i =1;i<10;i++){ System.out.println("wujiadong"+"--"+i); } } }
运行结果:
wujiadong--1
wujiadong--2
wujiadong--3
wujiadong--4
wujiadong--5
wujiadong--6
wujiadong--7
wujiadong--8
wujiadong--9
Demo run--1
Demo run--2
Demo run--3
Demo run--4
Demo run--5
Demo run--6
Demo run--7
Demo run--8
Demo run--9
Demo run--10
Demo run--11
Demo run--12
Demo run--13
Demo run--14
Demo run--15
Demo run--16
Demo run--17
Demo run--18
Demo run--19
方式二:实现Runnable接口
步骤:
- 定义类实现Runnable接口
- 覆盖Runnable接口中的run方法
- 创建Runnable接口的子类对象
- 创建Thread类对象,并把Runnable接口的子类对象作为构造参数传递
- 调用Thread类start方法开启线程并调用Runnable接口子类的run方法
例1:
class MyRunnable implements Runnable{ public void run(){ for(int i = 0;i<50;i++){ System.out.println(Thread.currentThread().getName()+"--"+i); } } } public class Example1{ public static void main(String[] arags){ MyRunnable mr = new MyRunnable(); /* //创建线程 Thread t1 = new Thread(mr); Thread t2 = new Thread(mr); //设置线程名称(推荐这种命名方法) t1.setName("wujiadong"); t2.setName("jiangrui"); */ //第二种线程命名方法 Thread t1 = new Thread(mr,"wujiadong"); Thread t2 = new Thread(mr,"jiangrui"); t1.start(); t2.start(); } }
Thread和Runnable的区别
- 继承Thread:线程代码存放在Thread子类run方法中
- 实现Runnable:线程代码存放在接口子类的run方法中
实现Runnable接口相对于继承Thread类的优点:
- 可共享一个目标对象,实现多个线程处理同一个资源
- 可避免java单线程的限制
线程的生命周期
- 新建状态(New): 创建线程对象就绪状态(Runnable): 线程对象创建后,其他线程调用该对象的start方法,该状态的线程位于可运行线程池中,变得可运行,等待获取CPU的使用权。即有执行资格无执行权
- 运行状态(Running): 就绪状态的线程获取了CPU,执行程序代码。即有执行资格,有执行权
- 堵塞状态(Blocked): 因为某种原因放弃CPU使用权,暂时停止运行。知道线程进入就绪状态,才有机会转到运行状态。即无执行资格无执行权
- 死亡状态(Terminated):线程执行完了或因异常退出了run()方法,该线程结束生命周期
线程调度
- 线程优先级
- 线程休眠
- 线程让步
- 线程插队
线程优先级
lass ThreadPriority extends Thread{ public void run(){ for(int i =0;i<50;i++){ System.out.println(Thread.currentThread().getName()+"--"+i); } } } public class Example13{ public static void main(String[] args){ ThreadPriority tp1 = new ThreadPriority(); ThreadPriority tp2 = new ThreadPriority(); ThreadPriority tp3 = new ThreadPriority(); tp1.setName("线程a"); tp2.setName("线程b"); tp3.setName("线程c"); //System.out.println(tp1.getPriority());获取默认的优先级 //设置优先级 tp1.setPriority(10); tp2.setPriority(5); tp3.setPriority(1); tp1.start(); tp2.start(); tp3.start(); } }
线程休眠
import java.util.Date; class MyThread extends Thread{ public void run(){ for(int i = 0;i<100;i++){ System.out.println(Thread.currentThread().getName()+"---"+i+",日期"+new Date()); try{ Thread.sleep(1000); }catch(InterruptedException e){ e.printStackTrace(); } } } } public class Example14{ 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(); } } /* 上面代码需注意捕获异常或抛出异常 部分运行结果 邬家栋---0,日期Mon Oct 17 04:36:19 PDT 2016 江睿---0,日期Mon Oct 17 04:36:19 PDT 2016 徐晴玉---0,日期Mon Oct 17 04:36:19 PDT 2016 邬家栋---1,日期Mon Oct 17 04:36:20 PDT 2016 江睿---1,日期Mon Oct 17 04:36:20 PDT 2016 徐晴玉---1,日期Mon Oct 17 04:36:20 PDT 2016 江睿---2,日期Mon Oct 17 04:36:21 PDT 2016 徐晴玉---2,日期Mon Oct 17 04:36:21 PDT 2016 邬家栋---2,日期Mon Oct 17 04:36:21 PDT 2016 */
线程让步
class MyThread extends Thread{ public void run(){ for(int i = 0;i<50;i++){ System.out.println(Thread.currentThread().getName()+"--"+i); Thread.yield();//暂停当前线程,并执行其他线程 } } } public class Example16{ public static void main(String[] args){ MyThread mt1 = new MyThread(); MyThread mt2 = new MyThread(); mt1.setName("wujiadong"); mt2.setName("jiangrui"); mt1.start(); mt2.start(); } } /* 部分结果 ... wujiadong--41 jiangrui--30 wujiadong--42 jiangrui--31 wujiadong--43 jiangrui--32 wujiadong--44 ... */
线程插队
class MyThread extends Thread{ public void run(){ for(int i=0;i<50;i++){ System.out.println(Thread.currentThread().getName()+"--"+i); } } } public class Example15{ public static void main(String[] args){ MyThread mt1 = new MyThread(); MyThread mt2 = new MyThread(); MyThread mt3 = new MyThread(); mt1.setName("wujiadong"); mt2.setName("jiangrui"); mt3.setName("sunqiangkun"); //加入join后等mt1线程运行完才开始运行mt2和mt3 mt1.start(); try{ mt1.join(); }catch(InterruptedException e){ e.printStackTrace(); } mt2.start(); mt3.start(); } } /* 部分运行结果 ... wujiadong--47 wujiadong--48 wujiadong--49 jiangrui--0 jiangrui--1 jiangrui--2 ... jiangrui--8 jiangrui--9 jiangrui--10 jiangrui--11 jiangrui--12 ... */
守护线程
class MyThread extends Thread{ public void run(){ for(int i = 0;i<100;i++){ System.out.println(Thread.currentThread().getName()+"---"+i); } } } public class Example17{ public static void main(String[] args){ MyThread mt1 = new MyThread(); MyThread mt2 = new MyThread(); mt1.setName("关羽"); mt2.setName("张飞"); //设置守护线程 mt1.setDaemon(true); mt2.setDaemon(true); mt1.start(); mt2.start(); Thread.currentThread().setName("刘备");//设置main线程名称 for(int x = 0;x<6;x++){ System.out.println(Thread.currentThread().getName()+x);//打印当前线程(main线程)名称 } } } /* 设置了关羽张飞两个为守护线程 只要刘备这个线程结束了,则另外两个线程也要结束。 */
java基础(3)-多线程(1)