疯狂java


您现在的位置: 疯狂软件 >> 新闻资讯 >> 正文

Java多线程-线程控制、线程组


 

 
join线程
假如A线程要B线程去完成一项任务,在B线程完成返回之前,不进行下一步执行,那么就可以调用B线程的join()方法
join()方法的重载:
join():等待不限时间
join(long millis):等待millis毫秒
join(long millis,int nanos):很少用,等待毫秒+毫微秒
看示例:
package testpack;
public class Test2  { 
    public static void main(String[] args) throws InterruptedException{ 
        System.out.println("现在线程是: "+Thread.currentThread().getName());
        A a=new A();
        Thread t1=new Thread(a,"被join线程");
        t1.start();                            //先start,后join
        t1.join();                             //调用join()方法
        System.out.println("主线程执行完毕");  //主线程要等t1线程执行完毕,才执行这条语句;如果不调用join(),可能主线程执行完了这条语句,才会执行t1
    }
}
class A implements Runnable{
    public void run(){
        for (int i=0;i<5;i++){
            System.out.println(Thread.currentThread().getName()+"  输出: "+i);
        }
    }
}
后台线程
后台线程,又叫守护线程,如果所有的前台线程都执行完毕,那么不论后台线程执行完毕与否,都直接进入死亡状态
前台创建的子线程是前台线程,后台线程创建的子线程是后台线程
setDaemon(boolean on):是否将该线程设为后台(true)线程,该方法要在start之前调用,否则抛出IllegalThreadStateException异常
isDaemon():判断该线程是不是后台线程
看示例:
package testpack;
public class Test2  { 
    public static void main(String[] args) throws InterruptedException{ 
        Thread t=new Thread(new A(),"后台线程");
        t.setDaemon(true);    //start之前调用setDaemon方法
        t.start();
        for (int i=0;i<10;i++){
            System.out.println(Thread.currentThread().getName()+" output: "+i);
        }
    }
}
class A implements Runnable{
    public void run(){
        for (int i=0;i<50;i++){
            System.out.println(Thread.currentThread().getName()+"  输出: "+i);
        }
    }
}
输出:
 
main output: 0
main output: 1
main output: 2
main output: 3
main output: 4
main output: 5
main output: 6
后台线程 输出: 0
main output: 7
后台线程 输出: 1
后台线程 输出: 2
后台线程 输出: 3
main output: 8
main output: 9
后台线程 输出: 4
后台线程 输出: 5 //后台线程本应执行到49,唯一的前台线程主线程结束后,后台线程也跟着死亡
 
线程sleep
sleep(long millis):
sleet(long millis,int nanos):
该方法让线程暂停执行,交出cpu的执行权,,进入阻塞状态,不释放锁,醒来之后进入就绪状态,不一定能立刻得到执行,看线程调度
示例:
package testpack;
 
import java.util.Date;
 
public class Test2  { 
    public static void main(String[] args) throws InterruptedException{ 
        System.out.println("当前时间:"+new Date());
        Thread.sleep(3000);
        System.out.println("当前时间:"+new Date());
    }
}
输出:
 
当前时间:Thu Dec 08 09:44:02 CST 2016
当前时间:Thu Dec 08 09:44:05 CST 2016 //主线程暂停执行3秒
 
线程yield
线程让步,会使线程从运行状态进入就绪状态,不会进入阻塞状态,这时会让线程优先级相同或更高的线程执行
示例
package testpack;
public class Test2  { 
    public static void main(String[] args) throws InterruptedException{ 
        A a1=new A("线程 低");
        A a2=new A("线程 中");
        A a3=new A("线程 高");
        a1.setPriority(Thread.MIN_PRIORITY);
        a2.setPriority(Thread.NORM_PRIORITY);
        a3.setPriority(Thread.MAX_PRIORITY);
        a1.start();
        a2.start();
        a3.start();
    }
}
class A extends Thread{
    A(String name){
        super(name);
    }
    public void run(){
        for (int i=1;i<10;i++){
            System.out.println(getName()+" 输出: "+i);
            if (i==3){
                Thread.yield();
            }
        }
    }
}
输出:
 
线程 低 输出: 1
线程 高 输出: 1
线程 中 输出: 1
线程 高 输出: 2
线程 低 输出: 2
线程 高 输出: 3
线程 中 输出: 2
线程 高 输出: 4
线程 低 输出: 3 //低级线程输出3后,yield,下面让高线程执行
线程 高 输出: 5
线程 中 输出: 3 //中级线程输出3后,也yield,下面让高线程执行
线程 高 输出: 6
线程 高 输出: 7
线程 高 输出: 8
线程 高 输出: 9
线程 低 输出: 4
线程 中 输出: 4
线程 中 输出: 5
.......
 
sleep与yield的对比
sleep:运行->阻塞->就绪;yield:运行->就绪
sleep之后,其他线程不论优先级高低,都有可能得到执行;yield之后,只有平级或更高级的线程才会被执行
sleep声明了抛出InterruptedException异常,yield没有
sleep方法移植性更强,不建议用yield来控制并发线程的执行
线程优先级
线程优先级可以是[1,10]的整数,由setPriority(int newPriority)设置
三个优先级常量:MAX_PRIORITY、NORM_PRIORITY、MIN_PRIORITY。值分别是10、5、1
每个线程的默认优先级跟创建它的父线程的优先级相同
为了更好的可移植性,建议使用优先级常量,少用int优先级
查看优先级:int getPriority()
线程组
每个线程都处于一个线程组中,通过线程组,可以对一批线程进行批量控制
如果没有指定线程组,那么处于默认线程组;子线程和创建它的父线程处于同一个线程组
如果要指定一个线程的线程组,应在构造方法中指定,创建了线程实例后,不能改变线程组
如何获得一个线程所属的线程组:getThreadGroup()
Thread的构造器中指定线程组
Thread(ThreadGroup group,Runnable target):
Thread(ThreadGroup group,Runnable target,String name):
Thread(ThreadGroup group,String name):
ThreadGroup的构造器
ThreadGroup(String name):以指定的名称、当前线程所属的线程组创建一个线程组
ThreadGroup(ThreadGroup parent, String name):以指定的名称、指定的父线程组创建一个线程组
ThreadGroup的几个方法
getName():返回该线程组的名字
操作该线程组下的所有线程
int activeCount():返回此线程组中活动线程的数目
void interrupt():中断该线程组中的所有线程
boolean isDaemon():判断是不是后台线程组
void setDaemon(boolean daemon):设置为后台线程组,其中的最后一个线程死亡之后,该线程组销毁。特别注意:后台线程组下的线程可不都是后台线程,二者无关
void setMaxPriority(int pri):设置该线程组的最高优先级
System.out.println(Thread.currentThread());
输出:Thread[main,5,main]:第一个main是线程名;5是线程优先级;第二个main是所属线程组名
 
示例:
package testpack;
public class Test2  { 
    public static void main(String[] args) throws InterruptedException{ 
        System.out.println("主线程名: "+Thread.currentThread().getName()
                +" ;所属线程组: "+Thread.currentThread().getThreadGroup().getName()
                +" ;是不是后台线程?"+Thread.currentThread().isDaemon());
        
        ThreadGroup tg=new ThreadGroup("后台线程组");
        tg.setDaemon(true);
        A a=new A(tg,"后台线程组的线程A");
        a.start();
    }
}
class A extends Thread{
    A(ThreadGroup group,String name){
        super(group,name);
    }
    public void run(){
        System.out.println("线程名: "+getName()+" ;所属线程组:"+getThreadGroup().getName()+" ;是不是后台线程?"+isDaemon());
    }
}
输出:
 
主线程名: main ;所属线程组: main ;是不是后台线程?false
线程名: 后台线程组的线程A ;所属线程组:后台线程组 ;是不是后台线程?false //后台线程组下的线程不一定是后台线程