浅谈java线程join方法使用方法
本博客简介介绍一下java线程的join方法，join方法是实现线程同步，可以将原本并行执行的多线程方法变成串行执行的
如图所示代码，是并行执行的
publicclassThreadTest{
//privatestaticfinalLongcount=10000L;
publicstaticvoidmain(String[]args){
longbase=System.currentTimeMillis();
try{
ThreadJoint1=newThreadJoin("线程1");
ThreadJoint2=newThreadJoin("线程2");
//t1.join();
t1.start();
t1.join();
t2.start();
}catch(Exceptione){
e.printStackTrace();
}
longtime=System.currentTimeMillis()-base;
System.out.println("执行时间："+time);
}
}
classThreadJoinextendsThread{
privatestaticfinalLongcount=10L;
publicThreadJoin(Stringname){
super(name);
}
@Override
publicvoidrun(){
//super.run();
for(inti=1;i<=count;i++){
System.out.println(this.getName()+":"+i);
}
}
}
打印出来的信息，都是这样的
执行时间：0
线程1:1
线程2:1
线程2:2
线程2:3
线程2:4
线程2:5
线程2:6
线程2:7
线程2:8
线程2:9
线程2:10
线程1:2
线程1:3
线程1:4
线程1:5
线程1:6
线程1:7
线程1:8
线程1:9
线程1:10
要实现串行执行，可以加上join方法，实现线程1执行完成后才开始执行线程2，也就是串行执行
publicclassThreadTest{
//privatestaticfinalLongcount=10000L;
publicstaticvoidmain(String[]args){
longbase=System.currentTimeMillis();
try{
ThreadJoint1=newThreadJoin("线程1");
ThreadJoint2=newThreadJoin("线程2");
//t1.join();
t1.start();
t1.join();
t2.start();
}catch(Exceptione){
e.printStackTrace();
}
longtime=System.currentTimeMillis()-base;
System.out.println("执行时间："+time);
}
}
classThreadJoinextendsThread{
privatestaticfinalLongcount=10L;
publicThreadJoin(Stringname){
super(name);
}
@Override
publicvoidrun(){
//super.run();
for(inti=1;i<=count;i++){
System.out.println(this.getName()+":"+i);
}
}
}
线程1:1
线程1:2
线程1:3
线程1:4
线程1:5
线程1:6
线程1:7
线程1:8
线程1:9
线程1:10
执行时间：0
线程2:1
线程2:2
线程2:3
线程2:4
线程2:5
线程2:6
线程2:7
线程2:8
线程2:9
线程2:10
从执行结果看，已经是串行执行线程
所以上面的例子是调了现场1的join方法，也就是说要先执行完成线程1，然后才执行main主线程
join方法的作用是，举个例子，在A线程里调B线程的join方法时，要先B线程执行完成，然后才会继续执行A线程
ok，上面调join方法是不加参数的，也可以加上参数，比如线程A.join(10)；，就是说线程A执行10s后，继续执行B线程
注意：join时间参数缺省的情况，默认是0，也就是说join()等同于join(0);
/** *Waitsforthisthreadtodie. * *Aninvocationofthismethodbehavesinexactlythesame *wayastheinvocation * *
*{@linkplain#join(long)join}{@code(0)} ** *@throwsInterruptedException *ifanythreadhasinterruptedthecurrentthread.The *interruptedstatusofthecurrentthreadis *clearedwhenthisexceptionisthrown. */ publicfinalvoidjoin()throwsInterruptedException{ join(0); }
Thread类里的源码，可以看出默认赋值为0，然后这个0是什么意思？0不是表示执行0s，而是表示要A线程执行完成才继续执行B线程的意思
ok，然后为什么调用了join方法就可以实现线程同步？我们简单看一下代码：
publicfinalsynchronizedvoidjoin(longmillis)
throwsInterruptedException{
longbase=System.currentTimeMillis();
longnow=0;
//执行时间必须为正数
if(millis<0){
thrownewIllegalArgumentException("timeoutvalueisnegative");
}
//执行时间为0或者缺省情况
if(millis==0){
while(isAlive()){//表示线程还没执行好
wait(0);//调用线程的wait方法
}
}else{//执行时间大于0的情况
while(isAlive()){
longdelay=millis-now;//循环计算延期时间
if(delay<=0){
break;
}
wait(delay);//同样调用线程的wait方法
now=System.currentTimeMillis()-base;
}
}
}
ok，看了一下源码，还是比较容易理解的，其实就是调用了现场wait方法实现线程同步的
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。