Java多线程学习

CIO之家的朋友　　博客园　　JAVA　　编辑:Morton 　　图片来源:网络

事实上Java里头线程全然能够写一本书了，可是假设最基本的你都学掌握好，又怎么能更上一个台阶呢？假设你认为此文非常简单，那推荐你看看Java并发包的的线程池（Java并发编程与技术内幕:线程池

本文主要讲了java中多线程的使用方法、线程同步、线程数据传递、线程状态及对应的一些线程函数使用方法、概述等。在这之前,首先让我们来了解下在操作系统中进程和线程的差别:

进程:每一个进程都有独立的代码和数据空间(进程上下文)。进程间的切换会有较大的开销,一个进程包括1--n个线程。(进程是资源分配的最小单位)

线程:同一类线程共享代码和数据空间,每一个线程有独立的执行栈和程序计数器(PC),线程切换开销小。(线程是cpu调度的最小单位)

线程和进程一样分为五个阶段:创建、就绪、执行、堵塞、终止。

多进程是指操作系统能同一时候执行多个任务(程序)。

多线程是指在同一程序中有多个顺序流在执行。

在java中要想实现多线程,有两种手段。一种是继续Thread类。第二种是实现Runable接口.(事实上准确来讲,应该有三种,还有一种是实现Callable接口,并与Future、线程池结合使用,此文这里不讲这个。

一、扩展java.lang.Thread类

这里继承Thread类的方法是比較经常使用的一种,假设说你仅仅是想起一条线程。没有什么其它特殊的要求,那么能够使用Thread.(笔者推荐使用Runable。后头会说明为什么)。

以下来看一个简单的实例

package com.multithread.learning; /**  *@functon 多线程学习  *@author 林炳文  *@time 2015.3.9  */ class Thread1 extends Thread{ private String name;     public Thread1(String name) {        this.name=name;     } public void run() {         for (int i = 0; i < 5; i++) {             System.out.println(name + "执行  :  " + i);             try {                 sleep((int) Math.random() * 10);             } catch (InterruptedException e) {                 e.printStackTrace();             }         }         } } public class Main { public static void main(String[] args) { Thread1 mTh1=new Thread1("A"); Thread1 mTh2=new Thread1("B"); mTh1.start(); mTh2.start(); } }

输出:

A执行 : 0
B执行 : 0
A执行 : 1
A执行 : 2
A执行 : 3
A执行 : 4
B执行 : 1
B执行 : 2
B执行 : 3
B执行 : 4

再执行一下:

A执行 : 0
B执行 : 0
B执行 : 1
B执行 : 2
B执行 : 3
B执行 : 4
A执行 : 1
A执行 : 2
A执行 : 3
A执行 : 4
说明:程序启动执行main时候,java虚拟机启动一个进程,主线程main在main()调用时候被创建。随着调用MitiSay的两个对象的start方法。另外两个线程也启动了,这样,整个应用就在多线程下执行。注意:start()方法的调用后并非马上执行多线程代码。而是使得该线程变为可执行态(Runnable),什么时候执行是由操作系统决定的。从程序执行的结果能够发现,多线程程序是乱序执行。因此,仅仅有乱序执行的代码才有必要设计为多线程。

Thread.sleep()方法调用目的是不让当前线程独自霸占该进程所获取的CPU资源,以留出一定时间给其它线程执行的机会。实际上全部的多线程代码执行顺序都是不确定的,每次执行的结果都是随机的。

可是start方法反复调用的话,会出现java.lang.IllegalThreadStateException异常。

Thread1 mTh1=new Thread1("A"); Thread1 mTh2=mTh1; mTh1.start(); mTh2.start();

输出:

Exception in thread "main" java.lang.IllegalThreadStateException
at java.lang.Thread.start(Unknown Source)
at com.multithread.learning.Main.main(Main.java:31)
A执行 : 0
A执行 : 1
A执行 : 2
A执行 : 3
A执行 : 4

二、实现java.lang.Runnable接口

採用Runnable也是非经常见的一种,我们仅仅须要重写run方法就可以。以下也来看个实例。

/**  *@functon 多线程学习  *@author 林炳文  *@time 2015.3.9  */ package com.multithread.runnable; class Thread2 implements Runnable{ private String name; public Thread2(String name) { this.name=name; } @Override public void run() {   for (int i = 0; i < 5; i++) {             System.out.println(name + "执行  :  " + i);             try {              Thread.sleep((int) Math.random() * 10);             } catch (InterruptedException e) {                 e.printStackTrace();             }         } } } public class Main { public static void main(String[] args) { new Thread(new Thread2("C")).start(); new Thread(new Thread2("D")).start(); } }

输出:

C执行 : 0
D执行 : 0
D执行 : 1
C执行 : 1
D执行 : 2
C执行 : 2
D执行 : 3
C执行 : 3
D执行 : 4
C执行 : 4

说明:Thread2类通过实现Runnable接口,使得该类有了多线程类的特征。run()方法是多线程程序的一个约定。全部的多线程代码都在run方法里面。Thread类实际上也是实现了Runnable接口的类。在启动的多线程的时候。须要先通过Thread类的构造方法Thread(Runnable target) 构造出对象。然后调用Thread对象的start()方法来执行多线程代码。实际上全部的多线程代码都是通过执行Thread的start()方法来执行的。因此,不管是扩展Thread类还是实现Runnable接口来实现多线程,终于还是通过Thread的对象的API来控制线程的。熟悉Thread类的API是进行多线程编程的基础。

三、Thread和Runnable的差别

假设一个类继承Thread。则不适合资源共享。可是假设实现了Runable接口的话,则非常easy的实现资源共享。

总结:

实现Runnable接口比继承Thread类所具有的优势:

1):适合多个同样的程序代码的线程去处理同一个资源

2):能够避免java中的单继承的限制

3):添加程序的健壮性,代码能够被多个线程共享,代码和数据独立

4):线程池仅仅能放入实现Runable或callable类线程,不能直接放入继承Thread的类

提醒一下大家:main方法事实上也是一个线程。在java中所以的线程都是同一时候启动的,至于什么时候。哪个先执行。全然看谁先得到CPU的资源。

在java中,每次程序执行至少启动2个线程。一个是main线程,一个是垃圾收集线程。

由于每当使用java命令执行一个类的时候,实际上都会启动一个JVM。每一个jVM实习在就是在操作系统中启动了一个进程。

四、线程状态转换

以下的这个图非常重要!

你假设看懂了这个图。那么对于多线程的理解将会更加深刻。

1、新建状态(New):新创建了一个线程对象。

2、就绪状态(Runnable):线程对象创建后,其它线程调用了该对象的start()方法。

该状态的线程位于可执行线程池中,变得可执行,等待获取CPU的使用权。

3、执行状态(Running):就绪状态的线程获取了CPU,执行程序代码。

4、堵塞状态(Blocked):堵塞状态是线程由于某种原因放弃CPU使用权。临时停止执行。直到线程进入就绪状态,才有机会转到执行状态。堵塞的情况分三种:

(一)、等待堵塞:执行的线程执行wait()方法,JVM会把该线程放入等待池中。

(wait会释放持有的锁)

(二)、同步堵塞:执行的线程在获取对象的同步锁时。若该同步锁被别的线程占用。则JVM会把该线程放入锁池中。

(三)、其它堵塞:执行的线程执行sleep()或join()方法。或者发出了I/O请求时。JVM会把该线程置为堵塞状态。当sleep()状态超时、join()等待线程终止或者超时、或者I/O处理完毕时。线程又一次转入就绪状态。(注意,sleep是不会释放持有的锁)

5、死亡状态(Dead):线程执行完了或者因异常退出了run()方法,该线程结束生命周期。

五、线程调度

线程的调度

1、调整线程优先级:Java线程有优先级,优先级高的线程会获得较多的执行机会。

Java线程的优先级用整数表示,取值范围是1~10。Thread类有以下三个静态常量:

static int MAX_PRIORITY
          线程能够具有的最高优先级,取值为10。
static int MIN_PRIORITY
          线程能够具有的最低优先级,取值为1。
static int NORM_PRIORITY
          分配给线程的默认优先级。取值为5。

Thread类的setPriority()和getPriority()方法分别用来设置和获取线程的优先级。

每一个线程都有默认的优先级。主线程的默认优先级为Thread.NORM_PRIORITY。

线程的优先级有继承关系,比方A线程中创建了B线程。那么B将和A具有同样的优先级。

JVM提供了10个线程优先级,但与常见的操作系统都不能非常好的映射。假设希望程序能移植到各个操作系统中,应该仅仅使用Thread类有以下三个静态常量作为优先级,这样能保证同样的优先级採用了同样的调度方式。

2、线程睡眠:Thread.sleep(long millis)方法,使线程转到堵塞状态。

millis參数设定睡眠的时间。以毫秒为单位。当睡眠结束后,就转为就绪(Runnable)状态。sleep()平台移植性好。

3、线程等待:Object类中的wait()方法,导致当前的线程等待,直到其它线程调用此对象的 notify() 方法或 notifyAll() 唤醒方法。这个两个唤醒方法也是Object类中的方法,行为等价于调用 wait(0) 一样。

4、线程让步:Thread.yield() 方法。暂停当前正在执行的线程对象。把执行机会让给同样或者更高优先级的线程。

5、线程添加:join()方法。等待其它线程终止。

在当前线程中调用还有一个线程的join()方法,则当前线程转入堵塞状态。直到还有一个进程执行结束,当前线程再由堵塞转为就绪状态。

6、线程唤醒:Object类中的notify()方法,唤醒在此对象监视器上等待的单个线程。假设全部线程都在此对象上等待。则会选择唤醒当中一个线程。选择是随意性的。并在对实现做出决定时发生。线程通过调用当中一个 wait 方法,在对象的监视器上等待。直到当前的线程放弃此对象上的锁定。才干继续执行被唤醒的线程。被唤醒的线程将以常规方式与在该对象上主动同步的其它全部线程进行竞争;比如,唤醒的线程在作为锁定此对象的下一个线程方面没有可靠的特权或劣势。相似的方法还有一个notifyAll(),唤醒在此对象监视器上等待的全部线程。

注意:Thread中suspend()和resume()两个方法在JDK1.5中已经废除,不再介绍。

由于有死锁倾向。

六、经常使用函数说明

①sleep(long millis): 在指定的毫秒数内让当前正在执行的线程休眠(暂停执行)
②join():指等待t线程终止。

使用方式。

join是Thread类的一个方法,启动线程后直接调用。即join()的作用是:“等待该线程终止”。这里须要理解的就是该线程是指的主线程等待子线程的终止。也就是在子线程调用了join()方法后面的代码,仅仅有等到子线程结束了才干执行。

Thread t = new AThread(); t.start(); t.join();

为什么要用join()方法

在非常多情况下,主线程生成并起动了子线程,假设子线程里要进行大量的耗时的运算。主线程往往将于子线程之前结束,可是假设主线程处理完其它的事务后。须要用到子线程的处理结果,也就是主线程须要等待子线程执行完毕之后再结束,这个时候就要用到join()方法了。

不加join。

/**
 *@functon 多线程学习,join
 *@author 林炳文
 *@time 2015.3.9
 */
package com.multithread.join;
class Thread1 extends Thread{
	private String name;
    public Thread1(String name) {
    	super(name);
       this.name=name;
    }
	public void run() {
		System.out.println(Thread.currentThread().getName() + " 线程执行開始!");
        for (int i = 0; i < 5; i++) {
            System.out.println("子线程"+name + "执行 : " + i);
            try {
                sleep((int) Math.random() * 10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println(Thread.currentThread().getName() + " 线程执行结束!");
	}
}
public class Main {
	public static void main(String[] args) {
		System.out.println(Thread.currentThread().getName()+"主线程执行開始!");
		Thread1 mTh1=new Thread1("A");
		Thread1 mTh2=new Thread1("B");
		mTh1.start();
		mTh2.start();
		System.out.println(Thread.currentThread().getName()+ "主线程执行结束!");
	}
}

输出结果:
main主线程执行開始!
main主线程执行结束!
B 线程执行開始!
子线程B执行 : 0
A 线程执行開始!
子线程A执行 : 0
子线程B执行 : 1
子线程A执行 : 1
子线程A执行 : 2
子线程A执行 : 3
子线程A执行 : 4
A 线程执行结束!
子线程B执行 : 2
子线程B执行 : 3
子线程B执行 : 4
B 线程执行结束!
发现主线程比子线程早结束
加join

public class Main {
	public static void main(String[] args) {
		System.out.println(Thread.currentThread().getName()+"主线程执行開始!");
		Thread1 mTh1=new Thread1("A");
		Thread1 mTh2=new Thread1("B");
		mTh1.start();
		mTh2.start();
		try {
			mTh1.join();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		try {
			mTh2.join();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println(Thread.currentThread().getName()+ "主线程执行结束!");
	}
}

执行结果:
main主线程执行開始!
A 线程执行開始!
子线程A执行 : 0
B 线程执行開始!
子线程B执行 : 0
子线程A执行 : 1
子线程B执行 : 1
子线程A执行 : 2
子线程B执行 : 2
子线程A执行 : 3
子线程B执行 : 3
子线程A执行 : 4
子线程B执行 : 4
A 线程执行结束!
主线程一定会等子线程都结束了才结束
③yield():暂停当前正在执行的线程对象,并执行其它线程。

Thread.yield()方法作用是:暂停当前正在执行的线程对象。并执行其它线程。

yield()应该做的是让当前执行线程回到可执行状态,以同意具有同样优先级的其它线程获得执行机会。因此。使用yield()的目的是让同样优先级的线程之间能适当的轮转执行。可是。实际中无法保证yield()达到让步目的。由于让步的线程还有可能被线程调度程序再次选中。

结论:yield()从未导致线程转到等待/睡眠/堵塞状态。在大多数情况下,yield()将导致线程从执行状态转到可执行状态,但有可能没有效果。

可看上面的图。

/**
 *@functon 多线程学习 yield
 *@author 林炳文
 *@time 2015.3.9
 */
package com.multithread.yield;
class ThreadYield extends Thread{
    public ThreadYield(String name) {
        super(name);
    }
 
    @Override
    public void run() {
        for (int i = 1; i <= 50; i++) {
            System.out.println("" + this.getName() + "-----" + i);
            // 当i为30时,该线程就会把CPU时间让掉,让其它或者自己的线程执行(也就是谁先抢到谁执行)
            if (i ==30) {
                this.yield();
            }
        }
	
}
}
public class Main {
	public static void main(String[] args) {
		
		ThreadYield yt1 = new ThreadYield("张三");
    	ThreadYield yt2 = new ThreadYield("李四");
        yt1.start();
        yt2.start();
	}
}

执行结果:

第一种情况:李四(线程)当执行到30时会CPU时间让掉,这时张三(线程)抢到CPU时间并执行。

第二种情况:李四(线程)当执行到30时会CPU时间让掉,这时李四(线程)抢到CPU时间并执行。

sleep()和yield()的差别
        sleep()和yield()的差别):sleep()使当前线程进入停滞状态。所以执行sleep()的线程在指定的时间内肯定不会被执行;yield()仅仅是使当前线程又一次回到可执行状态,所以执行yield()的线程有可能在进入到可执行状态后马上又被执行。
        sleep 方法使当前执行中的线程睡眼一段时间,进入不可执行状态,这段时间的长短是由程序设定的。yield 方法使当前线程让出 CPU 占有权,但让出的时间是不可设定的。实际上,yield()方法对应了例如以下操作:先检測当前是否有同样优先级的线程处于同可执行状态,如有。则把 CPU  的占有权交给此线程,否则,继续执行原来的线程。所以yield()方法称为“退让”,它把执行机会让给了同等优先级的其它线程
       另外。sleep 方法同意较低优先级的线程获得执行机会。但 yield()  方法执行时,当前线程仍处在可执行状态,所以。不可能让出较低优先级的线程些时获得 CPU 占有权。

在一个执行系统中。假设较高优先级的线程没有调用 sleep 方法。又没有受到 I\O 堵塞,那么,较低优先级线程仅仅能等待全部较高优先级的线程执行结束,才有机会执行。
④setPriority(): 更改线程的优先级。

MIN_PRIORITY = 1
NORM_PRIORITY = 5
MAX_PRIORITY = 10

使用方法:

Thread4 t1 = new Thread4("t1");
Thread4 t2 = new Thread4("t2");
t1.setPriority(Thread.MAX_PRIORITY);
t2.setPriority(Thread.MIN_PRIORITY);

⑤interrupt():不要以为它是中断某个线程。它仅仅是线线程发送一个中断信号,让线程在无限等待时(如死锁时)能抛出抛出。从而结束线程,可是假设你吃掉了这个异常,那么这个线程还是不会中断的!

⑥wait()

Obj.wait(),与Obj.notify()必须要与synchronized(Obj)一起使用,也就是wait,与notify是针对已经获取了Obj锁进行操作。从语法角度来说就是Obj.wait(),Obj.notify必须在synchronized(Obj){...}语句块内。

从功能上来说wait就是说线程在获取对象锁后,主动释放对象锁,同一时候本线程休眠。

直到有其它线程调用对象的notify()唤醒该线程。才干继续获取对象锁。并继续执行。

对应的notify()就是对对象锁的唤醒操作。但有一点须要注意的是notify()调用后,并非马上就释放对象锁的,而是在对应的synchronized(){}语句块执行结束。自己主动释放锁后。JVM会在wait()对象锁的线程中随机选取一线程,赋予其对象锁,唤醒线程。继续执行。这样就提供了在线程间同步、唤醒的操作。Thread.sleep()与Object.wait()二者都能够暂停当前线程,释放CPU控制权,基本的差别在于Object.wait()在释放CPU同一时候。释放了对象锁的控制。

单单在概念上理解清楚了还不够。须要在实际的样例中进行測试才干更好的理解。

对Object.wait(),Object.notify()的应用最经典的样例。应该是三线程打印ABC的问题了吧,这是一道比較经典的面试题,题目要求例如以下:

建立三个线程,A线程打印10次A,B线程打印10次B,C线程打印10次C,要求线程同一时候执行,交替打印10次ABC。这个问题用Object的wait(),notify()就能够非常方便的解决。代码例如以下:

/**
 * wait使用方法
 * @author DreamSea 
 * @time 2015.3.9 
 */
package com.multithread.wait;
public class MyThreadPrinter2 implements Runnable {   
	  
    private String name;   
    private Object prev;   
    private Object self;   
  
    private MyThreadPrinter2(String name, Object prev, Object self) {   
        this.name = name;   
        this.prev = prev;   
        this.self = self;   
    }   
  
    @Override  
    public void run() {   
        int count = 10;   
        while (count > 0) {   
            synchronized (prev) {   
                synchronized (self) {   
                    System.out.print(name);   
                    count--;  
                    
                    self.notify();   
                }   
                try {   
                    prev.wait();   
                } catch (InterruptedException e) {   
                    e.printStackTrace();   
                }   
            }   
  
        }   
    }   
  
    public static void main(String[] args) throws Exception {   
        Object a = new Object();   
        Object b = new Object();   
        Object c = new Object();   
        MyThreadPrinter2 pa = new MyThreadPrinter2("A", c, a);   
        MyThreadPrinter2 pb = new MyThreadPrinter2("B", a, b);   
        MyThreadPrinter2 pc = new MyThreadPrinter2("C", b, c);   
           
           
        new Thread(pa).start();
        Thread.sleep(100);  //确保按顺序A、B、C执行
        new Thread(pb).start();
        Thread.sleep(100);  
        new Thread(pc).start();   
        Thread.sleep(100);  
        }   
}

输出结果:

ABCABCABCABCABCABCABCABCABCABC

先来解释一下其总体思路。从大的方向上来讲,该问题为三线程间的同步唤醒操作,基本的目的就是ThreadA->ThreadB->ThreadC->ThreadA循环执行三个线程。

为了控制线程执行的顺序,那么就必须要确定唤醒、等待的顺序。所以每一个线程必须同一时候持有两个对象锁,才干继续执行。一个对象锁是prev。就是前一个线程所持有的对象锁。

还有一个就是自身对象锁。基本的思想就是,为了控制执行的顺序。必须要先持有prev锁,也就前一个线程要释放自身对象锁,再去申请自身对象锁,两者兼备时打印。之后首先调用self.notify()释放自身对象锁,唤醒下一个等待线程,再调用prev.wait()释放prev对象锁,终止当前线程,等待循环结束后再次被唤醒。执行上述代码,能够发现三个线程循环打印ABC,共10次。程序执行的主要过程就是A线程最先执行,持有C,A对象锁,后释放A,C锁,唤醒B。

线程B等待A锁,再申请B锁,后打印B,再释放B。A锁。唤醒C,线程C等待B锁,再申请C锁,后打印C,再释放C,B锁。唤醒A。看起来似乎没什么问题,但假设你细致想一下,就会发现有问题,就是初始条件,三个线程依照A,B,C的顺序来启动,依照前面的思考,A唤醒B,B唤醒C,C再唤醒A。可是这样的假设依赖于JVM中线程调度、执行的顺序。
wait和sleep差别
共同点:
1. 他们都是在多线程的环境下,都能够在程序的调用处堵塞指定的毫秒数。并返回。

2. wait()和sleep()都能够通过interrupt()方法打断线程的暂停状态 ,从而使线程立马抛出InterruptedException。
假设线程A希望马上结束线程B,则能够对线程B对应的Thread实例调用interrupt方法。

假设此刻线程B正在wait/sleep /join。则线程B会立马抛出InterruptedException。在catch() {} 中直接return就可以安全地结束线程。
须要注意的是,InterruptedException是线程自己从内部抛出的。并非interrupt()方法抛出的。对某一线程调用 interrupt()时。假设该线程正在执行普通的代码,那么该线程根本就不会抛出InterruptedException。

可是,一旦该线程进入到 wait()/sleep()/join()后,就会立马抛出InterruptedException 。
不同点:
1. Thread类的方法:sleep(),yield()等
Object的方法:wait()和notify()等
2. 每一个对象都有一个锁来控制同步訪问。Synchronizedkeyword能够和对象的锁交互,来实现线程的同步。
sleep方法没有释放锁。而wait方法释放了锁,使得其它线程能够使用同步控制块或者方法。

3. wait,notify和notifyAll仅仅能在同步控制方法或者同步控制块里面使用。而sleep能够在不论什么地方使用
所以sleep()和wait()方法的最大差别是:
sleep()睡眠时,保持对象锁,仍然占有该锁;
而wait()睡眠时。释放对象锁。
可是wait()和sleep()都能够通过interrupt()方法打断线程的暂停状态,从而使线程立马抛出InterruptedException(但不建议使用该方法)。
sleep()方法
sleep()使当前线程进入停滞状态(堵塞当前线程),让出CUP的使用、目的是不让当前线程独自霸占该进程所获的CPU资源。以留一定时间给其它线程执行的机会;
sleep()是Thread类的Static(静态)的方法;因此他不能改变对象的机锁。所以当在一个Synchronized块中调用Sleep()方法是,线程尽管休眠了。可是对象的机锁并木有被释放,其它线程无法訪问这个对象(即使睡着也持有对象锁)。
在sleep()休眠时间期满后,该线程不一定会马上执行,这是由于其它线程可能正在执行并且没有被调度为放弃执行。除非此线程具有更高的优先级。
wait()方法
wait()方法是Object类里的方法;当一个线程执行到wait()方法时,它就进入到一个和该对象相关的等待池中。同一时候失去(释放)了对象的机锁(临时失去机锁,wait(long timeout)超时时间到后还须要返还对象锁);其它线程能够訪问。
wait()使用notify或者notifyAlll或者指定睡眠时间来唤醒当前等待池中的线程。
wiat()必须放在synchronized block中。否则会在program runtime时扔出”java.lang.IllegalMonitorStateException“异常。

七、常见线程名词解释

主线程:JVM调用程序main()所产生的线程。

当前线程:这个是easy混淆的概念。一般指通过Thread.currentThread()来获取的进程。

后台线程:指为其它线程提供服务的线程,也称为守护线程。JVM的垃圾回收线程就是一个后台线程。用户线程和守护线程的差别在于,是否等待主线程依赖于主线程结束而结束

前台线程:是指接受后台线程服务的线程。事实上前台后台线程是联系在一起。就像傀儡和幕后操纵者一样的关系。傀儡是前台线程、幕后操纵者是后台线程。

由前台线程创建的线程默认也是前台线程。能够通过isDaemon()和setDaemon()方法来推断和设置一个线程是否为后台线程。

线程类的一些经常使用方法:
sleep(): 强迫一个线程睡眠N毫秒。
isAlive(): 推断一个线程是否存活。
join(): 等待线程终止。

activeCount(): 程序中活跃的线程数。
enumerate(): 枚举程序中的线程。
currentThread(): 得到当前线程。
isDaemon(): 一个线程是否为守护线程。
setDaemon(): 设置一个线程为守护线程。(用户线程和守护线程的差别在于,是否等待主线程依赖于主线程结束而结束)
setName(): 为线程设置一个名称。
wait(): 强迫一个线程等待。
notify(): 通知一个线程继续执行。

setPriority(): 设置一个线程的优先级。

八、线程同步

1、synchronizedkeyword的作用域有二种:
1)是某个对象实例内,synchronized aMethod(){}能够防止多个线程同一时候訪问这个对象的synchronized方法(假设一个对象有多个synchronized方法,仅仅要一个线程訪问了当中的一个synchronized方法。其它线程不能同一时候訪问这个对象中不论什么一个synchronized方法)。这时。不同的对象实例的synchronized方法是不相干扰的。也就是说,其它线程照样能够同一时候訪问同样类的还有一个对象实例中的synchronized方法。
2)是某个类的范围。synchronized static aStaticMethod{}防止多个线程同一时候訪问这个类中的synchronized static 方法。它能够对类的全部对象实例起作用。
2、除了方法前用synchronizedkeyword,synchronizedkeyword还能够用于方法中的某个区块中,表示仅仅对这个区块的资源实行相互排斥訪问。

使用方法是: synchronized(this){/*区块*/}。它的作用域是当前对象;
3、synchronizedkeyword是不能继承的。也就是说。基类的方法synchronized f(){} 在继承类中并不自己主动是synchronized f(){},而是变成了f(){}。继承类须要你显式的指定它的某个方法为synchronized方法;

Java对多线程的支持与同步机制深受大家的喜爱,似乎看起来使用了synchronizedkeyword就能够轻松地解决多线程共享数据同步问题。究竟怎样?――还得对synchronizedkeyword的作用进行深入了解才可定论。

总的说来。synchronizedkeyword能够作为函数的修饰符,也可作为函数内的语句,也就是平时说的同步方法和同步语句块。

假设再细的分类。synchronized可作用于instance变量、object reference(对象引用)、static函数和class literals(类名称字面常量)身上。

在进一步阐述之前,我们须要明白几点:

A.不管synchronizedkeyword加在方法上还是对象上,它取得的锁都是对象,而不是把一段代码或函数当作锁――并且同步方法非常可能还会被其它线程的对象訪问。

B.每一个对象仅仅有一个锁(lock)与之相关联。

C.实现同步是要非常大的系统开销作为代价的。甚至可能造成死锁,所以尽量避免无谓的同步控制。

接着来讨论synchronized用到不同地方对代码产生的影响:

假设P1、P2是同一个类的不同对象,这个类中定义了以下几种情况的同步块或同步方法。P1、P2就都能够调用它们。

1. 把synchronized当作函数修饰符时。演示样例代码例如以下:

Public synchronized void methodAAA()
{
//….
}

这也就是同步方法,那这时synchronized锁定的是哪个对象呢?它锁定的是调用这个同步方法对象。也就是说。当一个对象P1在不同的线程中执行这个同步方法时。它们之间会形成相互排斥,达到同步的效果。可是这个对象所属的Class所产生的还有一对象P2却能够随意调用这个被加了synchronizedkeyword的方法。

上边的演示样例代码等同于例如以下代码:

public void methodAAA()
{
synchronized (this)      //  (1)
{
       //…..
}
}

(1)处的this指的是什么呢?它指的就是调用这种方法的对象,如P1。可见同步方法实质是将synchronized作用于object reference。

――那个拿到了P1对象锁的线程,才干够调用P1的同步方法。而对P2而言。P1这个锁与它毫不相干。程序也可能在这样的情形下摆脱同步机制的控制,造成数据混乱:(

2.同步块,演示样例代码例如以下:

public void method3(SomeObject so)
              {
                     synchronized(so)
{
       //…..
}
}

这时,锁就是so这个对象,谁拿到这个锁谁就能够执行它所控制的那段代码。

当有一个明白的对象作为锁时,就能够这样敲代码,但当没有明白的对象作为锁,仅仅是想让一段代码同步时。能够创建一个特殊的instance变量(它得是一个对象)来充当锁:

class Foo implements Runnable
{
       private byte[] lock = new byte[0];  // 特殊的instance变量
    Public void methodA()
{
       synchronized(lock) { //… }
}
//…..
}

注:零长度的byte数组对象创建起来将比不论什么对象都经济――查看编译后的字节码:生成零长度的byte[]对象仅仅需3条操作码。而Object lock = new Object()则须要7行操作码。

3.将synchronized作用于static 函数。演示样例代码例如以下:

Class Foo
{
public synchronized static void methodAAA()   // 同步的static 函数
{
//….
}
public void methodBBB()
{
       synchronized(Foo.class)   //  class literal(类名称字面常量)
}
       }

代码中的methodBBB()方法是把class literal作为锁的情况。它和同步的static函数产生的效果是一样的,取得的锁非常特别,是当前调用这种方法的对象所属的类(Class。而不再是由这个Class产生的某个详细对象了)。

记得在《Effective Java》一书中看到过将 Foo.class和 P1.getClass()用于作同步锁还不一样,不能用P1.getClass()来达到锁这个Class的目的。P1指的是由Foo类产生的对象。

能够推断:假设一个类中定义了一个synchronized的static函数A,也定义了一个synchronized 的instance函数B,那么这个类的同一对象Obj在多线程中分别訪问A和B两个方法时。不会构成同步,由于它们的锁都不一样。A方法的锁是Obj这个对象,而B的锁是Obj所属的那个Class。

总结一下:

1、线程同步的目的是为了保护多个线程反问一个资源时对资源的破坏。

2、线程同步方法是通过锁来实现,每一个对象都有切仅有一个锁。这个锁与一个特定的对象关联,线程一旦获取了对象锁,其它訪问该对象的线程就无法再訪问该对象的其它非同步方法
3、对于静态同步方法,锁是针对这个类的。锁对象是该类的Class对象。静态和非静态方法的锁互不干预。一个线程获得锁,当在一个同步方法中訪问另外对象上的同步方法时,会获取这两个对象锁。

4、对于同步,要时刻清醒在哪个对象上同步。这是关键。
5、编写线程安全的类。须要时刻注意对多个线程竞争訪问资源的逻辑和安全做出正确的推断。对“原子”操作做出分析。并保证原子操作期间别的线程无法訪问竞争资源。
6、当多个线程等待一个对象锁时,没有获取到锁的线程将发生堵塞。
7、死锁是线程间相互等待锁锁造成的,在实际中发生的概率非常的小。真让你写个死锁程序。不一定好使,呵呵。可是。一旦程序发生死锁。程序将死掉。

九、线程数据传递

在传统的同步开发模式下,当我们调用一个函数时。通过这个函数的參数将数据传入。并通过这个函数的返回值来返回终于的计算结果。

但在多线程的异步开发模式下,数据的传递和返回和同步开发模式有非常大的差别。由于线程的执行和结束是不可预料的。因此,在传递和返回数据时就无法象函数一样通过函数參数和return语句来返回数据。

9.1、通过构造方法传递数据
在创建线程时,必须要建立一个Thread类的或其子类的实例。因此。我们不难想到在调用start方法之前通过线程类的构造方法将数据传入线程。

并将传入的数据使用类变量保存起来,以便线程使用(事实上就是在run方法中使用)。以下的代码演示了怎样通过构造方法来传递数据:

package mythread; 
public class MyThread1 extends Thread 
{ 
private String name; 
public MyThread1(String name) 
{ 
this.name = name; 
} 
public void run() 
{ 
System.out.println("hello " + name); 
} 
public static void main(String[] args) 
{ 
Thread thread = new MyThread1("world"); 
thread.start(); 
} 
}

由于这样的方法是在创建线程对象的同一时候传递数据的。因此,在线程执行之前这些数据就就已经到位了,这样就不会造成数据在线程执行后才传入的现象。假设要传递更复杂的数据,能够使用集合、类等数据结构。使用构造方法来传递数据尽管比較安全,但假设要传递的数据比較多时,就会造成非常多不便。

由于Java没有默认參数。要想实现相似默认參数的效果,就得使用重载。这样不但使构造方法本身过于复杂,又会使构造方法在数量上大增。因此,要想避免这样的情况,就得通过类方法或类变量来传递数据。

9.2、通过变量和方法传递数据
向对象中传入数据一般有两次机会。第一次机会是在建立对象时通过构造方法将数据传入。另外一次机会就是在类中定义一系列的public的方法或变量(也可称之为字段)。

然后在建立完对象后,通过对象实例逐个赋值。以下的代码是对MyThread1类的改版,使用了一个setName方法来设置 name变量:

package mythread; 
public class MyThread2 implements Runnable 
{ 
private String name; 
public void setName(String name) 
{ 
this.name = name; 
} 
public void run() 
{ 
System.out.println("hello " + name); 
} 
public static void main(String[] args) 
{ 
MyThread2 myThread = new MyThread2(); 
myThread.setName("world"); 
Thread thread = new Thread(myThread); 
thread.start(); 
} 
}

9.3、通过回调函数传递数据

上面讨论的两种向线程中传递数据的方法是最经常使用的。

但这两种方法都是main方法中主动将数据传入线程类的。这对于线程来说,是被动接收这些数据的。然而。在有些应用中须要在线程执行的过程中动态地获取数据,如在以下代码的run方法中产生了3个随机数,然后通过Work类的process方法求这三个随机数的和,并通过Data类的value将结果返回。从这个样例能够看出,在返回value之前,必须要得到三个随机数。也就是说,这个 value是无法事先就传入线程类的。

package mythread; 
class Data 
{ 
public int value = 0; 
} 
class Work 
{ 
public void process(Data data, Integer numbers) 
{ 
for (int n : numbers) 
{ 
data.value += n; 
} 
} 
} 
public class MyThread3 extends Thread 
{ 
private Work work; 
public MyThread3(Work work) 
{ 
this.work = work; 
} 
public void run() 
{ 
java.util.Random random = new java.util.Random(); 
Data data = new Data(); 
int n1 = random.nextInt(1000); 
int n2 = random.nextInt(2000); 
int n3 = random.nextInt(3000); 
work.process(data, n1, n2, n3); // 使用回调函数 
System.out.println(String.valueOf(n1) + "+" + String.valueOf(n2) + "+" 
+ String.valueOf(n3) + "=" + data.value); 
} 
public static void main(String[] args) 
{ 
Thread thread = new MyThread3(new Work()); 
thread.start(); 
} 
}