线程的概述:
线程是程序的多个执行路径,执行调度的单位,依托于进程存在。线程不仅可以共享进程的内存,而且还拥有一个属于自己的内存空间,这段内存空间叫做线程栈,是建立线程的时候由系统分配的,主要用来保存线程内部的数据,如线程执行函数中定义的变量。
java中多线程是一种抢占机制而不是分时机制。抢占机制是指CPU资源师被多个线程所共享,多个线程处于可运行状态,但是只允许一个线程在运行,他们通过竞争的方式抢占CPU.可以参考java 进程与线程的区别
线程的状态:
线程的方法和属性:
object.wait():用在同步中,如果不在锁中使用会抛出IllegalMonitorStateException异常。使线程处于阻塞状态,是线程进入等待池中,释放锁,释放执行权
Synchronizing Block:机锁具有独占性、一旦被一个Thread持有,其他的Thread就不能再拥有(不能访问其他同步方法),方法一旦执行,就独占该锁,直到从该方法返回时才将锁释放,此后被阻塞的线程方能获得该锁,重新进入可执行状态。
下面给出上面方法的测试代码:
yield(),join(),priority属性的测试,其它方法不测试了,在是我的文章里面可以看到:
设计两个线程,一个线程为主线程,一个线程Thread-0:
代码:没有用Join方法主线程和Thread-0交替的执行。大家都知道,这里不测试了。但是用了join方法大家看效果.
join方法的源码:
* Waits at most {@code millis} milliseconds for this thread to * die. A timeout of {@code 0} means to wait forever. * * <p> This implementation uses a loop of {@code this.wait} calls * conditioned on {@code this.isAlive}. As a thread terminates the * {@code this.notifyAll} method is invoked. It is recommended that * applications not use {@code wait}, {@code notify}, or * {@code notifyAll} on {@code Thread} instances. * * @param millis * the time to wait in milliseconds * * @throws IllegalArgumentException * if the value of {@code millis} is negative * * @throws InterruptedException * if any thread has interrupted the current thread. The * <i>interrupted status</i> of the current thread is * cleared when this exception is thrown. */ // 加锁当前线程 public final synchronized void join(long millis) throws InterruptedException { long base = System.currentTimeMillis(); long now = 0; if (millis < 0) { throw new IllegalArgumentException("timeout value is negative"); } if (millis == 0) { //A线程是start,在运行中 while (isAlive()) { //main线程等待 wait(0); } } else { //join(timeOut)的情况 while (isAlive()) { //根据当前timeout的时间-now 是否<=0进行判断,主线程是否继续阻塞等待 long delay = millis - now; //等待超时时间到了,则主线程不阻塞了,等待结束 if (delay <= 0) { break; } wait(delay); //子线程从循环开始到现在运行的时间 now = System.currentTimeMillis() - base; } } }
给一个例子来理解:
package concurrentMy.joins; /** * * @author Administrator * * main 线程 和 A线程,A线程是main线程创建并且启动的,main线程优先级比较高,正在执行; * 这个时候main线程调用A.join()之后,main线程一直等待,直到A线程运行完毕,main线程才运行 * */ class ThreadA extends Thread { public ThreadA(String name){ super(name); } @Override public void run() { 、 for (int i = 0; i < 20; i++) { // 复写父类的toString方法, 返回该线程的字符串表示形式,包括线程名称、优先级和线程组。 // Thread[Thread-1,5,main]默认的优先级为5,优先级从1-10 System.out.println(Thread.currentThread().getName() + "-" + i); } } } public class JoinDemo { /** * @param args * @throws InterruptedException */ public static void main(String[] args) throws InterruptedException { ThreadA A = new ThreadA("线程A"); A.start(); A.join(); //A线程加入到“main线程”中,main线程一直等待,直到A线程执行完毕,main线程才运行 System.out.println(Thread.currentThread().getName() + "执行"); System.out.println(Thread.currentThread().getName() + "执行终止"); } }
输出结果:
线程A-0 线程A-1 线程A-2 线程A-3 线程A-4 线程A-5 线程A-6 线程A-7 线程A-8 线程A-9 线程A-10 线程A-11 线程A-12 线程A-13 线程A-14 线程A-15 线程A-16 线程A-17 线程A-18 线程A-19 main执行 main执行终止
代码运行整个过程如下图:
例子2,优先级测试
package com.lp.ecjtu.Thread; /** * * @author Administrator * 当A线程执行到B线程的Join方法时,A就会等待,等B线程执行完之后,A线程才会执行 * Join方法可以用来临时加入线程执行 */ class Join implements Runnable{ @Override public void run() { for(int i=0;i<20;i++){ //复写父类的toString方法, 返回该线程的字符串表示形式,包括线程名称、优先级和线程组。 //Thread[Thread-1,5,main]默认的优先级为5,优先级从1-10 System.out.println(Thread.currentThread().toString()+"-"+i); } } } public class JoinDemo { /** * @param args * @throws InterruptedException */ public static void main(String[] args) throws InterruptedException { Join join = new Join(); Thread t1 = new Thread(join); Thread t2 = new Thread(join); t2.setPriority(Thread.MAX_PRIORITY);//设置线程的优先级的方法 t1.start(); t2.start(); } }
输出结果:
Thread[Thread-1,10,main]-0
Thread[Thread-1,10,main]-1
Thread[Thread-1,10,main]-2
Thread[Thread-1,10,main]-3
Thread[Thread-1,10,main]-4
Thread[Thread-1,10,main]-5
Thread[Thread-1,10,main]-6
Thread[Thread-0,5,main]-0
Thread[Thread-1,10,main]-7
Thread[Thread-1,10,main]-8
Thread[Thread-0,5,main]-1
Thread[Thread-1,10,main]-9
Thread[Thread-1,10,main]-10
Thread[Thread-1,10,main]-11
Thread[Thread-1,10,main]-12
Thread[Thread-1,10,main]-13
Thread[Thread-1,10,main]-14
Thread[Thread-1,10,main]-15
Thread[Thread-1,10,main]-16
Thread[Thread-1,10,main]-17
Thread[Thread-1,10,main]-18
Thread[Thread-0,5,main]-2
Thread[Thread-1,10,main]-19
Thread[Thread-0,5,main]-3
Thread[Thread-0,5,main]-4
Thread[Thread-0,5,main]-5
Thread[Thread-0,5,main]-6
Thread[Thread-0,5,main]-7
Thread[Thread-0,5,main]-8
Thread[Thread-0,5,main]-9
Thread[Thread-0,5,main]-10
Thread[Thread-0,5,main]-11
Thread[Thread-0,5,main]-12
Thread[Thread-0,5,main]-13
Thread[Thread-0,5,main]-14
Thread[Thread-0,5,main]-15
Thread[Thread-0,5,main]-16
Thread[Thread-0,5,main]-17
Thread[Thread-0,5,main]-18
Thread[Thread-0,5,main]-19
总结:从结果可以看出Thread-1,10,main优先级为10的线程2先执行。
yield方法是正在执行的线程释放执行权,暂停执行一小会儿。这里不测了。。。。。。