Java线程开发和多线程并发
1.1并发与并行
- 并发 :指两个或多个事件在同一个时间段内发生 。
- 并行 :指两个或多个事件在同一时刻发生(同时发生)。
1.2线程与进程
-
进程:是指一个内存中运行得应用程序,每个进程都有一个独立得内存空间,一个应用程序可以同时运行多个进程;进程也是程序得一次执行过程,是系统运行程序的基本单位;系统运行一个程序即是一个进程从创建运行到消亡得过程。(进入到内存中的程序叫进程)
-
线程:线程是进程中的一个执行单元,负责当前进程中程序的执行,一个进程中至少有一个线程,一个进程中是可以有多个线程的,这个应用程序也可以称之为多线程程序。
线程调度:
-
分时调度
所有线程轮流使用CPU的使用权,平均分配每个线程占用CPU的时间。
-
抢占式调度
优先让优先级高的线程使用CPU,如果线程的优先级相同,那么会随机选择一个线程(线程随机性),java使用的为抢占式调度。
主线程中的单线程:
/* 主线程:执行主(main)方法的线程 单线程程序: java程序只有一个线程 执行从main方法开始,从上到下依次执行 */ /* JVM执行main方法,main方法会进入到栈内存 JVM会找操作系统开辟一条main方法通向cpu的执行路径 cpu就可以通过这个路径来执行main方法 而这个路径有一个名字 交main线程 */ public class MainThread { public static void main(String[] args) { Person person = new Person("阿珍"); person.run(); Person person1 = new Person("阿强"); person1.run(); } }
创建线程类:
/*
创建多线程程序的第一种方式:创建Thread的子类
java.lang.Thread类:是描述线程的类,我们想要实现多线程程序,就必须继承Thread类
步骤:
1 创建一个Thread的子类
2 在Thread类的子类中重写Thread类中的run方法,设置线程任务(开启线程要做什么)
3 创建Thread类的子类对象
4 调用Thread类中的start方法,开启新的线程,执行run方法
void start()使该线程开始执行;java 虚拟机调用该线程的run方法
结果是两个线程并发的去运行;当前线程(main线程)和另一个线程(新创建的线程,执行run方法)
多此启动一个线程是非法的。特别是当前线程已结束后,不能再重新启动。
java程序属于抢占式调度, 那个程序优先级高 就先执行那个, 如果优先级相同 随机
*/
//1 创建一个Thread的子类 public class MyThread extends Thread { // 2 在Thread类的子类中重写Thread类中的run方法,设置线程任务(开启线程要做什么) public void run(){ for (int i = 0; i < 20; i++) { System.out.println("run"+i); } } }
public class Demo01Thread { public static void main(String[] args) { //创建Thread类的子类对象 MyThread myThread= new MyThread(); //调用Thread类中的start方法,开启新的线程,执行run方法 myThread.start(); for (int i = 0; i < 20; i++) { System.out.println("main"+i); } }
多线程程序的内存图解:
main方法中创建了一个Thread类的对象:
调用了一个 satart方法
在run方法中 进行for循环
方法的执行需要栈内存 程序进入main方法后进行压栈 一行一行的执行我们的方法 。
new的对象在堆内存里 对象给一个地址值 把地址值给mt
当我执行mt.run方法的时候 这时候run会进行压栈 如果这样的话我们的程序就会是一个单线程的程序。
当我们一调用mt.start方法 就会在开辟新的栈空间然后执行run方法 (run方法就不会再我们的主方法里面执行)。
在new MyThread().start();就会在开辟新的栈空间然后执行run方法
然后 我们的 CPU 就有了选择的权利
获取线程的名称:
//定义一个Thread类的子类 public class MyThread extends Thread { //重写run方法 @Override public void run() { //获取线程名称 /* String name = getName();
System.out.println(name);*/ /* Thread t=Thread.currentThread();
System.out.println(t);
System.out.println(t.getName());*/ //链式编程 System.out.println(Thread.currentThread().getName()); } }
/*
设置线程的名称:(了解)
1. 使用Thread类中的方法setName
void setName (String name ) 改变线程名称,使之与参数相同
2. 创建一个带参数的构造方法,参数传递线程的名称;调用父类的带参构造方法,把线程名给父类 让父类
(Thread)给子线程起一个名字 Thread(String name) 分配一个新的 Thread 对象
*/
1.使用Thread类中的方法setName
public class MyTread extends Thread { @Override public void run() { System.out.println(Thread.currentThread().getName()); } }
public class DemoThread { public static void main(String[] args) { //new 一个线程的子类对象 MyTread myTread = new MyTread(); myTread.setName("阿珍"); //阿珍 //开启线程 myTread.start(); } }
2.创建一个带参数的构造方法,参数传递线程的名称
public class MyTread extends Thread { public MyTread(){} public MyTread(String name){ super(name); } @Override public void run() { System.out.println(Thread.currentThread().getName()); } }
public class DemoThread { public static void main(String[] args) { //开启一个新的线程 new MyTread("阿强").start(); //阿强 } }
public static void sleep (long millis)
使当前正在执行的线程已指定的毫秒数暂停(暂时停止执行)。
/*
public static void sleep (long millis)当前正在执行的线程已指定的毫秒数暂停(暂时停止执行)。
*/ public class DemoThread { public static void main(String[] args) { //模拟秒表 for (int i = 0; i <= 60; i++) { System.out.println(i); //使用sleep让程序睡眠1秒钟 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }
线程创建的第二种方式:
/*
创建多线程程序的第二种方式:实现Runnable接口
java.long.Runnable
Runnable接口应该有哪些打算通过某一线程执行其实例的类来实现,类必须定义一个无参数的方法,称为run
java.lang.Thread类的构造方法
Thread(Runnable target) 分配新的Thread 对象
Thread(Runnable target,String name) 分配新的 Thread 对象
实现步骤:
1.创建一个Runnable接口的实现类
2.在实现类中重写Runnable 接口的run方法,设置线程任务
3.创建一个Runnable接口的实现类对象
4.创建Thread类对象,构造方法中传递Runnable接口的实现类对象
5.调用Thread类中的start方法,开启新的线程执行的run方法
*/ public class MyTread { public static void main(String[] args) { //3.创建一个Runnable接口的实现类对象 RunnableImpl runnable = new RunnableImpl(); // 4.创建Thread类对象,构造方法中传递Runnable接口的实现类对象 Thread thread = new Thread(runnable); //调用Thread类中的start方法,开启新的线程执行的run方法 thread.start(); for (int i = 0; i <=20; i++) { System.out.println(Thread.currentThread().getName()+"------->"+i); }} }
// 1.创建一个Runnable接口的实现类 public class RunnableImpl implements Runnable { // 2.在实现类中重写Runnable 接口的run方法,设置线程任务 @Override public void run() { for (int i = 0; i <=20; i++) { System.out.println(Thread.currentThread().getName()+"------->"+i); } } }
Thread 和 Runnable的区别:
如果一个类继承Thread,则不适合资源共享。但是如果实现了Runable接口的话,则很容易的实现资源共享。
实现Runnable接口比继承Thread类所具有的优势:
1.适合多个相同的程序代码的线程共享同一个资源。
2.可以避免java中的单继承的局限性
一个类只能继承一个类(一个人只能有一个亲爹),类继承了Thread类就不能继承其他的类
实现了runnable接口,还可以
3.增加程序的健壮性,实现解耦操作,代码可以被多个线程共享,代码和线程独立
4.线程池只能放入实现Runnable或Callable类线程,不能直接放入继承Thread的类
扩充:在java中,每次程序运行至少启动2个线程,一个是main线程,一个是垃圾收集线程。
因为每当使用java命令启动一个类的时候,实际上都会启动一个JVM,每一个JVM其实就是
在操作系统中启动了一个进程
匿名内部类方式创建线程:
public class IoDemo04 { public static void main(String[] args) { new Thread(){ //重写run方法 设置线程任务 @Override public void run() { for (int i = 0; i < 20; i++) { System.out.println(Thread.currentThread().getName()+"---"+i+"giao"); } } }.start(); //接口的方式 new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 20; i++) { System.out.println(Thread.currentThread().getName()+"---"+i+"yao"); } } }).start(); } }
本文地址:https://blog.csdn.net/agood_man/article/details/108205543
上一篇: 指定字段上传Kafka写入txt文件并文件上传ftp服务器
下一篇: JPA如何使用(快速上手)