基础的多进程
子线程的创建
进程：正在运行的一个程序QQ IDE 浏览器,系统会为这个进程分配独立的内存资源
线程：具体执行任务的最小单位
一个进程最少拥有一个线程 （主线程 运行起来就执行的线程）
线程之间是共享内存资源的（进程申请的）,线程之间可以通信（数据传递：多数为主线程和子线程）
每一个线程都有自己的运行回路（生命周期)
为什么需要创建子线程
- 如果在主线程存在比较耗时的操作：下载视频 上传文件 数据这些操作会阻塞主线程、后面的任务的任务必须等这些任务执行完毕之后才能执行
- 用户体验比较差
- 为了不阻塞主线程，后面的任务必须放到子线程中去处理
子线程的创建
1.写一个类继承于Thread 实现run方法
注意这里面的一些使用要点
join:让当前这个线程阻塞 等join的线程执行完毕再执行 - setName：设置线程名称
- getName：获取线程名称
- currentThread：获取当前运行的线程对象
- start: 开启任务
*NEW：新建 线程刚被创建好 - RUNNABLE:run runnable就绪状态（只要抢到时间片就可以运行）
- BLOCKED：阻塞状态 sleep wait
- WAITING:等待wait
- TIMED WAITING
代码实现
public static void main(String[] args) {
//main方法里面执行的代码 是在主线程里面执行的
TestThread tt=new TestThread();
//设置线程的名称
tt.setName("子线程1");
//开启任务
tt.start();
}
class TestThread extends Thread {
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(i + 1);
}
super.run();
}
}
2.实现Runnable接口 实现run方法
- a创建任务
- b使用Thread 为这个任务分配线程
- c开启任务 start
public static void main(String[] args) {
hmlTread pt = new hmlTread();
Thread t = new Thread(pt);
t.setName("子线程1");
t.start();
Thread t2 = new Thread(pt);
t2.setName("子线程2");
t2.start();
}
class hmlTread implements Runnable {
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(Thread.currentThread()+":"+i);
}
}
}
线程安全
sychronized Lock 加锁解锁
* sychronized 同步监听器 需要一把锁
* 任何一个对象都有自己的一把锁
* 如果多个线程操作同一个代码块，并且需要同步
* 那么必须操作同一个对象/同一个对象的同一把锁
* 1.同步代码块
* synchronize（监听器/对象/锁）{
* //需要同步的代码块
* }
锁里面还有wait notifi notifiAll方法
就是指的阻塞、唤醒、唤醒全部
public static void main(String[] args) {
Ticket ticketCQ=new Ticket("重庆");
Thread t1=new Thread(ticketCQ);
t1.start();
Ticket ticketSH=new Ticket("上海");
Thread t2=new Thread(ticketSH);
t2.start();
}
class Ticket implements Runnable {
// //定义所有车票数量
public static int num = 100;
String name;
public Ticket(String name) {
this.name = name;
}
static final Object obj = new Object();
@Override
public void run() {
for (int i = 0; i < 100; i++) {
//判断有没有票
synchronized (obj) {
if (num > 0) {
System.out.println(name + "出票" + num);
num--;
obj.notify();
try {//当前线程等待
obj.wait();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
//通知其它线程执行
}
} else {
break;
}
}
}
}
}
2.ReentrantLock 可重入锁
class Ticket implements Runnable {
// //定义所有车票数量
public static int num = 100;
String name;
public Ticket(String name) {
this.name = name;
}
static final Object obj = new Object();
static ReentrantLock lock=new ReentrantLock();
Condition condition=lock.newCondition();
//创建一个可重入的锁
//
@Override
public void run() {
for (int i = 0; i < 100; i++) {
//判断有没有票
lock.lock();
if (num > 0) {
System.out.println(name + "出票" + num);
num--;
try {//当前线程等待
//obj.wait();
condition.signal();
condition.await();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
//通知其它线程执行
}
} else {
break;
}
lock.unlock();
}
}
}
synchronized其实和ReentrantLock实现的功能都差不多，都是加锁，只不过可以使用的方法名不同而已。
