在native code中使用多线程好处多多,但是Android的bionic并没有完全实现标准POSIX线程库的所有API,例如pthread_cancel()。但是google这样做肯定有原因,被cancel的thread不一定已经把自己拥有的资源释放掉,因此很可能带来内存泄露,锁没有释放等问题。这些问题在移动设备上更加突出。
首先介绍一个指标的方法,使用signal替代cancel调用:
当worker thread超时时,在主线程(或者是监视进程)中调用
[cpp] view plain copy if((status=pthread_kill(pthread_id,SIGUSR1))!=0) { printf("Errorcancellingthread%d,error=%d(%s)",pthread_id,status,strerrorstatus)); }
在worker thread中加入对SIGUSR1信号的处理
[cpp] view plain copy structsigactionactions; memset(&actions,0,sizeof(actions)); sigemptyset(&actions.sa_mask); actions.sa_flags=0; actions.sa_handler=thread_exit_handler; rc=sigaction(SIGUSR1,&actions,NULL); voidthread_exit_handler(intsig) { printf("thissignalis%d\n",sig); pthread_exit(0); } 参考自: http://stackoverflow.com/questions/4610086/pthread-cancel-alternatives-in-android-ndk
最根本的解决方法是重写worker thread,使用poll或者select等处理IO操作防止stuck的发生,下面是Android源码system/libsysutils/src/SocketListener.cpp的处理方法
1,创建worker thread前先创建通讯管道
[cpp] view plain copy if(pipe(mCtrlPipe)){ SLOGE("pipefailed(%s)",strerror(errno)); return-1; } if(pthread_create(&mThread,NULL,SocketListener::threadStart,this)){ SLOGE("pthread_create(%s)",strerror(errno)); return-1; }
2,在worker thread的大循环中使用select同时监控管道和IO fd
[cpp] view plain copy while(1){//一般工作进程都带一个大循环 FD_SET(mCtrlPipe[0],&read_fds); if(mCtrlPipe[0]>max) max=mCtrlPipe[0]; if((rc=select(max+1,&read_fds,NULL,NULL,NULL))<0){ SLOGE("selectfailed(%s)",strerror(errno)); sleep(1); continue; }elseif(!rc) continue; //有人喊停了 if(FD_ISSET(mCtrlPipe[0],&read_fds)) break; }
3,需要退出时通过管道通知worker thread
[cpp] view plain copy if(write(mCtrlPipe[1],&c,1)!=1){ SLOGE("Errorwritingtocontrolpipe(%s)",strerror(errno)); return-1; } 相关资源:Java 面经手册·小傅哥(公众号:bugstack虫洞栈).pdf