android bionic欠落pthread_cancelの解決方法
native codeでマルチスレッドを使用するメリットは多いが、Androidのbionicはpthread_などの標準POSIXスレッドライブラリのすべてのAPIを完全に実現していない.cancel().しかしGoogleがこのようにするのは、cancelのthreadによって自分の持っているリソースが解放されたとは限らないため、メモリの漏洩、ロックの解放がないなどの問題をもたらす可能性が高い.これらの問題はモバイルデバイスでより顕著である.
まず、cancel呼び出しの代わりにsignalを使用する指標の方法を紹介します.
worker threadが超過した場合、プライマリ・スレッド(または監視プロセス)で呼び出されます.
worker threadにSIGUSR 1信号の処理を加える
最も根本的な解決策はworker threadを書き換え、pollやselectなどを用いてIO操作を処理してstuckの発生を防止することであり、以下はAndroidソースsystem/libsysutils/src/SocketListener.cppの処理方法である
1,worker threadを作成する前に通信パイプを作成する
2,worker threadの大サイクルでselectを使用してパイプとIO fdを同時に監視する
3、終了する必要がある場合はパイプでworker threadに通知する
まず、cancel呼び出しの代わりにsignalを使用する指標の方法を紹介します.
worker threadが超過した場合、プライマリ・スレッド(または監視プロセス)で呼び出されます.
if ( (status = pthread_kill(pthread_id, SIGUSR1)) != 0)
{
printf("Error cancelling thread %d, error = %d (%s)", pthread_id, status, strerror status));
}
worker threadにSIGUSR 1信号の処理を加える
struct sigaction actions;
memset(&actions, 0, sizeof(actions));
sigemptyset(&actions.sa_mask);
actions.sa_flags = 0;
actions.sa_handler = thread_exit_handler;
rc = sigaction(SIGUSR1,&actions,NULL);
void thread_exit_handler(int sig)
{
printf("this signal is %d
", 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を作成する前に通信パイプを作成する
if (pipe(mCtrlPipe)) {
SLOGE("pipe failed (%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を同時に監視する
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("select failed (%s)", strerror(errno));
sleep(1);
continue;
} else if (!rc)
continue;
//
if (FD_ISSET(mCtrlPipe[0], &read_fds))
break;
}
3、終了する必要がある場合はパイプでworker threadに通知する
if (write(mCtrlPipe[1], &c, 1) != 1) {
SLOGE("Error writing to control pipe (%s)", strerror(errno));
return -1;
}