黑马程序员_多线程

------- android培训、java培训、期待与您交流！ ----------

 

 

1.进程

正在执行的程序, 在内存中占用空间. 

2. 线程

进程的具体的执行路径(线索),一个进程中至少会有一个线程.当然一个进程中可以存在多个线程.  

3. 多线程

存在的意义,可以提高cpu 资源的利用率. 避免cpu 的闲置. 

多线程,不会让程序变的更快,很有可能由于多个线程之前的切换,导致变慢的(线程之间切换时,需要消耗资源的)

4.java多线程. 

jvm支持多线程.

java是完全面向对象的语言,提供了专业的类表示线程.-> Thread类. 

java 创建线程的方式: 

java 中创建线程的方式有二种. 

方式一: 使用继承方式. 

1.定义类继承Thread 类 

2.重写run方法, 该方法中定义需要线程执行的任务(代码)

3.创建该类对象-> 线程创建出来了. 

4.调用start(继承父类)的方法,启动线程... 

线程执行, 抢占cpu 的执行权, 抢到了就执行run方法中的代码... 

方式二:  使用实现. 接口方式. 

1. 实现类实现Runnable 接口. 

2. 重写接口中的run 方法. 

3. 创建实现类对象. 

4. 创建Thread 类对象,并通过构造函数接收Runnable接口的实现类对象. 

5. Thread 对象调用start 方法. 

推荐使用方式二:

1.语法保留继承. 

java 只支持单继承,如果使用继承方式,创建线程,无法继承其他类. 

如果使用实现的方式,还可以保留一个继承... 还可以继承其他类... 

2.使用接口方式,更加符合面向对象的思想. 

|---接口的实现类对象, 定义线程需要执行的任务... 

|---单独的创建Thread 对象, 创建了线程. 

将任务和线程分离了.. 既可以一个线程执行一个任务, 也可以多个线程执行同一个任务. 

面向对象: 万物皆对象... 

5. 多线程的安全问题. 

什么情况下会出现线程安全问题. 

1. 充分条件, 多个线程... 

2. 必要条件, 多个线程修改了共享的数据, 如果知识获取共享数据,不会出现问题...

6.解决多线程的安全问题. 

例如: 银行账户, 有卡, 有折. 

两个人同时取钱, 一个去ATM ,一个去柜台, 相当于并发了程序, 多线程的程序. 两个线程同时执行... 

两个线程要修改共享的数据, 导致线程的安全问题. 

解决安全问题

使用同步代码块. 

synchronized(对象){

需要同步的代码; 

}

对象可以是任意类型的. 只需要对象要保证唯一性. 

多个线程持有的对象,同一个,才能解决多线程的安全问题.  

7.线程的常见方法. 

1. 构造函数

Thread(String name);

初始化线程名

getName();

获取线程名

setName();

设置线程名

getId();

获取线程的id 

setPriority

设置线程优先级. 

windows 范围是1~10 默认是5. 

getPriority

获取线程优先级. 

run

提供给子类重写使用的. 

子类可以在改方法中定义需要线程执行的任务. 

启动线程后,线程自动的地调用run方法. 

如果创建一个线程对象之后,不调用start ,直接调用run方法, 不会真正的开启一个线程,仅仅执行普通的run 方法. 

start

开启线程的. 

只有Thread 类才具备start 方法, 只有Thread 对象才能表示线程才能开启线程. 

注意: 一旦使用start 方法之后,不能再次调用. 一个线程对象不能开启2次... 

一个java 程序启动后,至少会有2个以上的线程... 

主线程. 垃圾回收机制(后台线程)

sleep(毫秒);

程序睡眠, 线程释放了cpu  cpu 执行其他的线程了... 

注意:  如果多线程的,有一个线程持有了同步的锁对象, 并且遇到了sleep ,即时该线程释放了cpu, 不释放锁对象. 其他线程获取cpu,也无法进入同步代码块中执行... 

currentThread()

静态方法. 

获取当前线程对象. 

stop(); 

过时的, 结束线程. 

所谓的过时的方法,不再建议使用... 

可以通过布尔标记控制线程... 

8. 同步方法. 

非静态同步方法:

修饰符  synchronized 返回值类型  函数名(){

 

} 

如果同步方法是非静态的,该方法默认的锁对象就是this. 

注意: 同步方法使用的锁对象是this, 不一定能够保证对象的唯一性... 尤其通过继承方式创建的多线程下... 

静态同步方法:

修饰符  synchronized static 返回值类型  函数名(){

 

} 

静态同步方法默认锁对象是该类的字节码对象. 类名.class. 

单例设计模式?

饿汉

懒汉

懒汉式,在多线程下出现安全问题, 在多线程无法保证单例对象的唯一性... 

使用了双重判断. 

StringBuilder

1.5  不同步. ->效率高. 注意,如果是多线程. 应该使用StringBuffer;  

StringBuffer

1.0  同步 -> 效率低.  在单线程下不需要同步的. 

9.死锁. 

多线程下. 多个锁. 

线程T1,线程T2, 锁对象C1, 锁对象C2. 

程序执行 T1持有C2,想要获取C1, 

      T2持有的是C1,想要C2. 

哲学家就餐问题:

写一个死锁程序

10. 线程通信

wait 

notify 

11.线程的生命周期.

新状态

可运行

运行

阻塞

死亡. 

12.后台线程. 

软件升级.

普通软件:

后台线程,检测是否更新,如果有更新,弹窗,提示是否更新...  

当你的软件运行的时间较短,,, 更新程序没来得及获取到最新的状态. 程序就结束了... 如果是后台线程,直接停止了... 

后台线程:

普通的非后台线程最大的区别,  如果一个程序的所有的非后台线程执行完毕了, 该程序即使该后后台线程没有执行完毕,后台线程要结束了

13.特殊的方法. 

join.  等待该线程结束. 

 

例子：

   package cn.itcast.c_thread2;

 

public class DataMoveDemo1 {

public static void main(String[] args) {

Person p = new Person();

Input in = new Input(p);

Output out = new Output(p);

 

Thread t1 = new Thread(in);

Thread t2 = new Thread(out);

 

t1.start();

t2.start();

 

}

}

 

class Person {

private String name;

private String gender;

 

private boolean flag = true;

 

/**

* 从mySql读取了数据,使用对象存储数据.

*/

public synchronized void set(String name, String gender) {

if (flag) {

this.name = name;

this.gender = gender;

flag = false;

 

// 唤醒对方线程 

notify(); 

// 释放cpu 执行权... 同时释放锁.

try {

wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

 

public synchronized void get() {

if (!flag) {

System.out.println(this.name + "---------" + this.gender);

flag = true;

 

// 线程等待之前,唤醒对方线程... 让对方线程执行. 

notify(); 

// 释放cpu 释放锁.

try {

wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

 

}

}

}

 

/**

 * 读取mySql 获取数据. 并使用对象存储数据.

 * */

class Input implements Runnable {

Person p;

 

int i;

 

Input(Person p) {

this.p = p;

}

 

@Override

public void run() {

while (true) {

 

if (i % 2 == 0) {

p.set("jack", "male");

} else {

p.set("小丽", "女");

}

i++;

 

}

}

}

 

class Output implements Runnable { // ctrl+1

Person p;

 

public Output(Person p) {

this.p = p;

}

 

@Override

public void run() {

while (true) {

p.get();

}

}

 

}