Linux pthread 和 java thread 的是 / 非守护线程的行为

pthread_xxx 的函数并没有直接提供设置一个 pthread 为守护线程的 API

而 pthread_attr_init() 和 struct pthread_attr_t 也并没有提供 线程是否被设置为守护线程的成员变量

但 java 的线程对象有 setDaemon() 方法将线程设置为守护线程

那我们看看 java 的 Thread 的 native 层是如何实现该变量的功能的voidThread::CreateNativeThread(JNIEnv*env,jobject java_peer,size_tstack_size,boolis_daemon){

...

623Thread*child_thread=newThread(is_daemon);// is_daemon 是关键

...

好像和 native 的 pthread 并没有什么关系... 可能和 jvm 里有相关处理逻辑.

所以说 Linux 下是不存在原生的 pthread 是否为守护进程概念的 (最多只有守护进程概念)

Linux 下 pthread 行为:

L1. 子线程为守护线程 (默认情况, Linux 下创建 pthread 天生就是守护线程, 行为和 J2. java 中调用 setDaemon(true) 后一致):

1.mainThread 跑完 main 函数, subThread 立刻退出, mainThread 退出, 整个进程退出

2.subThread 跑完, subThread 退出, mainThread 跑完 main 函数, mainThread 退出, 整个进程退出

java 下 thread 行为:

J1. 子线程不为守护线程 (默认情况, java 下创建 thread 天生不是守护进程):

1.mainThread 跑完 main 函数, subThread 立刻退出, mainThread 退出, jvm 退出, 进程退出

2.subThread 跑完, subThread 退出, mainThread 跑完 main 函数, mainThread 退出, jvm 退出, 进程退出

J2. 子线程为守护线程 (调用 setDaemon(true), 和 Linux 下子线程创建后, 行为和 Linux 中默认创建 pthread 后一致):

1.mainThread 跑完 main 函数, subThread 继续跑到退出, subThread 退出, mainThread 退出, jvm 退出, 进程退出

2.subThread 跑完, subThread 退出, mainThread 跑完 main 函数, mainThread 退出, jvm 退出, 进程退出

总结

1. 守护线程行为

Linux 下默认创建线程 = java 下创建后调用 setDeamon(true)

行为: 只要主线程执行完了, 守护线程立刻销毁, 进程退出

2. 非守护线程行为

Linux 下无法直接将线程设置为非守护进程 = java 下默认创建的线程默认就是非守护线程

行为: 任何一个非守护线程执行完了, 立刻销毁自己 (无论主线程还是子线程), 整个进程中非守护进程数量 > 0, 进程不会退出; 整个进程中非守护进程数量 == 0, 立刻剩余销毁守护进程, 并退出进程

L1 代码:

L1.1.#include

#include

#include

voidmsleep(unsignedints){

printf("tid: %d, start sleep %d\n",pthread_self(),s);

sleep(s);

printf("tid: %d, end sleep %d\n",pthread_self(),s);

}

intfun2(){

printf("fun2() start\n");

pthread_detach(pthread_self());

printf("current tid:%d\n",pthread_self());

msleep(5);

printf("fun2() end\n");

return1;

}

voidmain(){

intres;

pthread_tpt2;

printf("main() start\n");

//pthread_attr_init();

res=pthread_create(&pt2,NULL,fun2,NULL);

//printf("res: %d\n",res);

msleep(3);

printf("main() end\n");

}

输出[emailprotected]:~/cdir/dthreaddemo# ./dt1

main()start

tid:-1624217856,start sleep3

fun2()start

current tid:-1632536832

tid:-1632536832,start sleep5

tid:-1624217856,endsleep3

main()end

可以看到并没有 fun2() end 输出

L2.2.

代码#include

#include

#include

voidmsleep(unsignedints){

printf("tid: %d, start sleep %d\n",pthread_self(),s);

sleep(s);

printf("tid: %d, end sleep %d\n",pthread_self(),s);

}

intfun2(){

printf("fun2() start\n");

pthread_detach(pthread_self());

printf("current tid:%d\n",pthread_self());

msleep(3);

printf("fun2() end\n");

return1;

}

voidmain(){

intres;

pthread_tpt2;

printf("main() start\n");

//pthread_attr_init();

res=pthread_create(&pt2,NULL,fun2,NULL);

//printf("res: %d\n",res);

msleep(5);

printf("main() end\n");

}

输出[emailprotected]:~/cdir/dthreaddemo# ./dt1

main()start

tid:-1453377792,start sleep5

fun2()start

current tid:-1461696768

tid:-1461696768,start sleep3

tid:-1461696768,endsleep3

fun2()end

tid:-1453377792,endsleep5

main()end

J1.1

代码publicclassTest1{

publicstaticvoidmain(String[]args){

System.out.println("main start");

Threadt2=newThread(newRunnable(){

@Override

publicvoidrun(){

System.out.println("t2 start");

try{

Thread.sleep(5000);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("t2 end");

}

});

// t2.isDaemon(); //default is false

t2.setDaemon(false);

t2.start();

try{

Thread.sleep(3000);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("t2.isAlive()"+t2.isAlive());

System.out.println("main end");

}

}

输出main start

t2 start

t2.isAlive()true

mainend

t2end

Processfinishedwithexitcode0

J1.2.

代码publicclassTest1{

publicstaticvoidmain(String[]args){

System.out.println("main start");

Threadt2=newThread(newRunnable(){

@Override

publicvoidrun(){

System.out.println("t2 start");

try{

Thread.sleep(3000);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("t2 end");

}

});

// t2.isDaemon(); //default is false

t2.setDaemon(false);

t2.start();

try{

Thread.sleep(5000);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("t2.isAlive()"+t2.isAlive());

System.out.println("main end");

}

}

输出main start

t2 start

t2end

t2.isAlive()false

mainend

Processfinishedwithexitcode0

J2.1.

代码publicclassTest1{

publicstaticvoidmain(String[]args){

System.out.println("main start");

Threadt2=newThread(newRunnable(){

@Override

publicvoidrun(){

System.out.println("t2 start");

try{

Thread.sleep(5000);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("t2 end");

}

});

// t2.isDaemon(); //default is false

t2.setDaemon(true);

t2.start();

try{

Thread.sleep(3000);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("t2.isAlive()"+t2.isAlive());

System.out.println("main end");

}

}

输出main start

t2 start

t2.isAlive()true

mainend

Processfinishedwithexitcode0

J2.2.

代码publicclassTest1{

publicstaticvoidmain(String[]args){

System.out.println("main start");

Threadt2=newThread(newRunnable(){

@Override

publicvoidrun(){

System.out.println("t2 start");

try{

Thread.sleep(3000);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("t2 end");

}

});

// t2.isDaemon(); //default is false

t2.setDaemon(true);

t2.start();

try{

Thread.sleep(5000);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("t2.isAlive()"+t2.isAlive());

System.out.println("main end");

}

}

输出main start

t2 start

t2end

t2.isAlive()false

mainend

Processfinishedwithexitcode0

这里不考虑线程调度的极端问题, 如活锁之类的, 或导致某个线程一致无法被分配到时间片等情况.

来源: http://www.bubuko.com/infodetail-3388958.html