----------------------
Android开发、java培训、期待与您交流! ----------------------
线程与进程是程序运行中体现的两个名词,它包含这不同的程序域。进程指的是一个正在运行的程序,如:360,QQ运行时就是不同的两个进程。当你打开windows任务管理器时,看到的每个进程就是此时windows中正在运行的程序。线程则就是进程中的一个个独立的控制单元,线程控制着进程的执行,也就是说每个正在运行的程序中就包括着很多的线程。
主线程:Java虚拟机运行时会有一个Java.exe的进程执行,该进程中至少有一个线程负责Java程序的运行,而这个线程运行的代码在main方法中,此时该线程成为主线程。
多线程:一个进程中可以同时运行多个线程,很明显多线程可以提高程序的运行的速度。(虽然说是同时运行,其实cup在同一时刻只能运行一个线程,cup在做着快速的切换动作,由于速度极其的快,看上去就好像是同时运行,但多核除外)。
创建线程有两种方法:
⑴继承Thread类
①定义类继承Thread类。
②重写Thread类的run()方法。
---->将线程要运行的代码定义在run()方法中。
③调用Thread类中的start()方法。
----->启动线程,须调用start()方法,不用手动调用run()方法,start()方法会调用run()方法。
⑵实现Runnable接口
①定义类实现Runnable接口。
------>这个实现Runnable接口的类是需要多线程执行的类
②重写Runnable接口中的run()方法。
------>Runnable接口中只有一个抽象方法run()方法,Thread类也实现了Runnable。
③需要多少个线程就创建多少个Thread类对象。(没考虑主线程)
------>一个Thread类对象就是一个线程
④将Runable接口的子类对象作为实际参数传递给Thread类的构造函数。
----->自定义的run方法所属的对象是Runable接口的子类对象,所以要让线程去指定对象的run方法。
⑤调用Thread类中start()方法启动线程既而run()方法也就被执行了。
----->执行start()方法就会自动执行run()方法。
创建线程的两种方法的区别与优劣:
实现Runnable接口的方法避免了Java单继承的局限性,在创建线程时建议使用实现的方法。
继承Thread:线程代码存在Thread子类run方法中。
实现Runable:线程代码存在接口的子类的run方法。
多线程的安全问题
当多条语句操作同一个线程共享数据时,一个线程对语句只执行了一部分,另一个线程就进来执行了,导致共享数据的错误。
解决方法:
对多条共享数据的语句,只能让一个线程都执行完了其它线程才可以去执行,在执行过程中,其他线程不可以参与执行,java对于多线程的安全问题提供了专业的解决方法,那就是同步代码块。
synchronized(对象)
{
需要被同步的代码
}
同步代码块使用的关键字是synchronized,所传递的对象为任意对象,这个对象就相当于锁,持有锁的线程才可以执行被同步的代码,否则就算拥有cpu执行权,也进不来。当被同步代码执行完释放锁后下一个待执行的线程才可以进去。
同步的前提:
①必须要有两个或两个以上的线程执行共享代码
----->只有这样同步才会有意义。
②必须是多线程使用同一个锁
------>对于多个synchronized(对象){},这个对象必须是同一对象,才可以做到未释放锁之前,只有一个线程在执行同步代码。
同步的优劣
优点:解决了多线程的线程安全问题。
劣点:每执行同步时都要判断锁,耗时,较为消耗资源,使用不当时会造成死锁。
同步方法
public synchronized void function(){}
在非静态方法上加上synchronized关键字,与同步代码块功能相同,只是同步方法的锁是this,指的是当前类对象,而同步代码块的锁可以使任何对象。
public static synchronized void function(){}
当同步方法为静态时,与同步代码块和非静态方法的区别只是锁,此时静态同步方法的锁为该方法所在类的字节码文件对象, 类名.class。静态进入内存时,内存中没有本类对象,但是一定有该类对应的字节码文件对象。
Thread类中常用的操作线程的方法介绍
① static void sleep(int millis)
在指定的毫秒数内让当前正在执行的线程休眠(暂停执行),此操作受到系统计时器和调度程序精度和准确性的影响。
② static Thread currentThread()
返回对当前正在执行的线程对象的引用。通常与getName()使用。
③ String getName()
返回该线程的名称。 通常与currentThread()使用来获取当前正在执行的线程的名称,Thread.currentThread().getName()。
④ void start()
使该线程开始执行;Java 虚拟机调用该线程的 run 方法。
⑤ String toString()
返回该线程的字符串表示形式,包括线程名称、优先级和线程组。
⑥ void setPriority(int newPriority)
更改线程的优先级。
⑦ static void yield()
暂停当前正在执行的线程对象,并执行其他线程。
⑧ void interrupt()
中断线程。
⑨ void join()
等待该线程终止。
⑩ void setDaemon(boolean on)
将该线程标记为守护线程或用户线程。
㈡定义在 Object类中的三类操作线程的方法介绍
① void notify()
唤醒在此对象同步上等待的单个线程。
② void notifyAll()
唤醒在此对象同步上等待的所有线程。
③ void wait()
在其他线程调用此对象的 notify() 方法或 notifyAll() 方法前,导致当前线程等待。
为什么这三类操作线程的方法要定义在Object类中呢?
这些方法存在同步中,使用这些方法时必须要标识所属的同步锁,锁可以是任意对象调用的方法一定定义Object类中。
wait()与sleep()的区别:
wait():释放资源,释放锁。
sleep():释放资源,不释放锁。
等待唤醒机制
等待唤醒机制要对持有监视器(锁)的线程操作,所以要使用在同步中,因为只有同步才具有锁。必须要用到锁,等待和唤醒都必须定义到锁中。同时必然会用到wait()、notify()和notifyAll()三个方法。
第一个实例:
得到一个人的信息,就打印这个人的信息,不可以得到多人再打印,也不可得到一个人重复打印多次。所以要使用多线程,并且要使用同步才能够解决。
⑴定义一个资源类(Res),描述资源。
⑵定义两个线程类,一个输入(Input)类,一个输出(Output)类,让他们都实现Runnable接口。
⑶定义main方法类,即为主线程。
class Res { private String name; private String sex; private boolean flag = false; public synchronized void set(String name,String sex) { if(flag) try{this.wait();}catch(Exception e){} this.name = name; this.sex = sex; flag = true; this.notify(); } public synchronized void out() { if(!flag) try{this.wait();}catch(Exception e){} System.out.println(name+"...."+sex); flag = false; this.notify(); } } class Input implements Runnable { private Res r; Input(Res r) { this.r = r; } public void run() { int x = 0; while (true) { if(x==0) r.set("Mike","man"); else r.set("丽丽","女女"); x = (x+1)%2; } } } class Output implements Runnable { private Res r; Output(Res r) { this.r = r; } public void run() { while (true) { r.out(); } } } class InputOutputDemo { public static void main(String[] srgs) { Res r = new Res(); new Thread(new Input(r)).start(); new Thread(new Ontput(r)).start(); } }第二个实例
生产者/消费者的程序来演示多个线程对共享资源的竞争。
(1)ProducerConsumerDemo类:提供程序入口main()方法,负责创建生产者和消费者线程,并且启动这些线程。
(2)producer类:生产者线程,不断向堆栈中加入产品。
(3)Consumer类:消费者线程,不断向堆栈中取出产品。
(4)Resource类:是资源类,允许从堆栈中取出或加入产品。
class ProducerConsumerDemo { public static void main(String[] args) { Resource r = new Resource(); Producer pro = new Producer(r); Consumer con = new Consumer(r); Thread t1 = new Thread(pro); Thread t2 = new Thread(pro); Thread t3 = new Thread(con); Thread t4 = new Thread(con); t1.start(); t2.start(); t3.start(); t4.start(); } } class Resource { private String name; private int count = 1; private boolean flag = false; public synchronized void set(String name) { while(flag) try{this.wait();}catch(Exception e){} this.name = name+"--"+count++; System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name); flag = true; this.notifyAll(); } public synchronized void out() { while(!flag) try{this.wait();}catch(Exception e){} System.out.println(Thread.currentThread().getName+"...消费者..."+this.name); flag = false; this.notifyAll(); } } class Producer implements Runnable { private Resource res; Producer{Resource res} { this.res = res; } public void run() { while(true) { res.set("+商品+"); } } } class Consumer implements Runnable { private Resource res; Consumer{Resource res} { this.res = res; } public void run() { while(true) { res.out("+商品+"); } } }JDK1.5中提供了多线程升级解决方案
class ProducerConsumerDemo { public static void main(String[] args) { Resource r = new Resource(); Producer pro = new Producer(r); Consumer con = new Consumer(r); Thread t1 = new Thread(pro); Thread t2 = new Thread(pro); Thread t3 = new Thread(con); Thread t4 = new Thread(con); t1.start(); t2.start(); t3.start(); t4.start(); } } class Resource { private String name; private int count = 1; private boolean flag = false; private Lock lock =new ReentrantLock(); private Condition condition_pro = lock.newCondition(); private Condition condition_con = lock.newCondition(); public void set(String name)throws InterruptedException { lock.lock();//获取锁。 try { while(flag) condition_pro.await(); this.name = name+"--"+count++; System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name); flag = true; condition_con.signal(); } finally { lock.unlock();//释放锁的动作一定要执行。 } } public void out()throws InterruptedException { lock.lock(); try { while(!flag) condition_con.await(); System.out.println(Thread.currentThread().getName+"...消费者..."+this.name); flag = false; condition_pro.signal(); } finally { lock.unlock(); } } } class Producer implements Runnable { private Resource res; Producer{Resource res} { this.res = res; } public void run() { while(true) { res.set("+商品+"); } } } class Consumer implements Runnable { private Resource res; Consumer{Resource res} { this.res = res; } public void run() { while(true) { res.out("+商品+"); } } }线程中的常用操作解决方案:
一、停止线程。
最早用Thread类中stop()方法,但由于stop()方法具有不安全性,所以不建议使用了,成为过时方法。然而想让线程停止另有其它好方法。实际上停止线程就是停止run()方法。
(1)更改循环标记(终止循环)
----->因为线程运行代码一般都是循环结构,只要控制了循环即可.
----->但就算是要更改循环标记,如果当再更改循环标记之前wait()了,并不能立即结束线程,那该怎么办?此时线程机制任然还有其它好方法。如(2)可见。
(2)使用interrupt()方法,清除如wait()等方法的冻结状态,就会有机会读到标记,既而有机会终止循环终止线程。
------>该方法是结束线程的冻结状态,使线程回到运行状态中来。
二、守护线程。
守护线程又称用户线程也称后台线程,Java中用setDaemon()方法设置线程是否为守护线程,此方法参数为boolean类型,当传递true时则设置为守护线程否则为前台线程。
注意:
(1)setDaemon(boolean on)方法设置是否为守护线程,传递true则为守护线程,否则为前台线程。
(2)当所有线程都为守护线程时,则jvm就会退出。
(3)当所有的前台线程结束了,则守护线程也就都结束了。
(4)若前台线程没有结束,后台线程可结束也可不结束,全在设定。
(5)垃圾回收线程为守护线程。
三、join()等待线程终止。
此方法是Thread类中的,用来操作线程,意思是让别的线程等待直到当前执行线程执行结束。
Resource r = new Resource(); Producer pro = new Producer(r); Consumer con = new Consumer(r); Thread t1 = new Thread(pro); Thread t2 = new Thread(pro); Thread t3 = new Thread(con); Thread t4 = new Thread(con); t1.start(); //① t2.start(); //② t3.start().join(); //③ t4.start(); //④主线程执行①②代码,启动t1和t2两个线程,此时主线程、t1、t2这三个线程交替执行,当执行③代码时,t3线程被启动,遇到join()方法,此时主线程立即冻结,主线程不会执行④代码,t4线程暂时不会被启动。t1、t2、t3这三个线程交替执行,直到t3线程执行结束,这时主线程被激活当抢到执行权时t4线程才会被启动,如果t1和t2还没执行结束,则此时就是t1、t2、t4、主线程抢夺cpu执行权了。
四、Thread类中toString()方法
它执行结果就是打印"线程名 优先级 线程组",线程名为Thread.currentThread().getName()的结果,优先级也就是线程被执行的频率,抢夺到cpu执行权的频率。线程组按我的理解应该是在哪个线程中启动了当前线程,则就是哪个线程的线程名。
五、线程优先级
线程优先级即为线程执行到的频率,优先级定义为int,是1---10之间的整数,1表示被执行到的频率最低,10表示被执行到的频率最高。它有以下5种操作线程优先级的方法。
(1) public static final int MIN_PRIORITY
----->线程可以具有优先级最低,它的优先级实际上为1.
(2)public static final int NORM_PRIORITY
----->线程可以具有优先级为中等,是线程默认的优先级,它的优先级实际上为5
(3)public static final int MAX_PRIORITY
------>线程可以具有优先级为最高,它的优先级实际上为10.
(4)setPriority(int newPriority)
------>更改优先级,可向方法中传递1----10的整数代表优先级的高低。
(5)int getPriority()
------>返回线程的优先级。
【总结】
在学习多线程的过程中,Java多线程的方方面面都给我们代码带来了灵活性和快捷性,包括创建线程,以及对多个线程进行调度、管理,我们深刻认识到了多线程编程的复杂性,以及线程切换开销带来的多线程程序的低效性,这也促使我们认真地思考一个问题:我们是否需要多线程?何时需要多线程?
多线程的核心在于多个代码块并发执行,本质特点在于各代码块之间的代码是乱序执行的。我们的程序是否需要多线程,就是要看这是否也是它的内在特点。
假如我们的程序根本不要求多个代码块并发执行,那自然不需要使用多线程;假如我们的程序虽然要求多个代码块并发执行,但是却不要求乱序,则我们完全可以用一个循环来简单高效地实现,也不需要使用多线程;只有当它完全符合多线程的特点时,多线程机制对线程间通信和线程管理的强大支持才能有用武之地,这时使用多线程才是值得的。
---------------------- Android开发、java培训、期待与您交流! ----------------------详细请查看:www.itheima.com
黑马程序员---Java多线程,布布扣,bubuko.com
原文地址:http://blog.csdn.net/xuyankuanrong/article/details/27222401