Android bionic缺失pthread_cancel的解決方法

在native code中使用多線程好處多多，但是Android的bionic並沒有完全實現標准POSIX線程庫的所有API，例如pthread_cancel()。但是google這樣做肯定有原因，被cancel的thread不一定已經把自己擁有的資源釋放掉，因此很可能帶來內存洩露，鎖沒有釋放等問題。這些問題在移動設備上更加突出。

首先介紹一個指標的方法，使用signal替代cancel調用：

當worker thread超時時，在主線程（或者是監視進程）中調用

1. if ( (status = pthread_kill(pthread_id, SIGUSR1)) != 0)
2. {
3. printf("Error cancelling thread %d, error = %d (%s)", pthread_id, status, strerror status));
4. }

在worker thread中加入對SIGUSR1信號的處理

1. struct sigaction actions;
2. memset(&actions, 0, sizeof(actions));
3. sigemptyset(&actions.sa_mask);
4. actions.sa_flags = 0;
5. actions.sa_handler = thread_exit_handler;
6. rc = sigaction(SIGUSR1,&actions,NULL);
7. void thread_exit_handler(int sig)
8. {
9. printf("this signal is %d \n", sig);
10. pthread_exit(0);
11. }

最根本的解決方法是重寫worker thread，使用poll或者select等處理IO操作防止stuck的發生，下面是Android源碼system/libsysutils/src/SocketListener.cpp的處理方法

1，創建worker thread前先創建通訊管道

1. if (pipe(mCtrlPipe)) {
2. SLOGE("pipe failed (%s)", strerror(errno));
3. return -1;
4. }
6. if (pthread_create(&mThread, NULL, SocketListener::threadStart, this)) {
7. SLOGE("pthread_create (%s)", strerror(errno));
8. return -1;
9. }

2，在worker thread的大循環中使用select同時監控管道和IO fd

1. while(1){ // 一般工作進程都帶一個大循環
2. FD_SET(mCtrlPipe[0], &read_fds);
3. if (mCtrlPipe[0] > max)
4. max = mCtrlPipe[0];
5. if ((rc = select(max + 1, &read_fds, NULL, NULL, NULL)) < 0) {
6. SLOGE("select failed (%s)", strerror(errno));
7. sleep(1);
8. continue;
9. } else if (!rc)
10. continue;
12. // 有人喊停了
13. if (FD_ISSET(mCtrlPipe[0], &read_fds))
14. break;
15. }

3，需要退出時通過管道通知worker thread

1. if (write(mCtrlPipe[1], &c, 1) != 1) {
2. SLOGE("Error writing to control pipe (%s)", strerror(errno));
3. return -1;
4. }