1

私が達成したいのは、メイン スレッドが最初にワーカー スレッドで通常の遅延キャンセルを試行し (私の目的ではブラック ボックスであるコードを実行する)、次にスレッドがまだタイムアウト後も実行されている場合 ( pthread_timedjoin_np())、非同期キャンセルを行います。私が抱えている問題はpthread_setcanceltype()、呼び出し元のスレッドのみです。これを可能にする回避策やハックはありますか? 少なくともLinuxでは、非同期キャンセルがスレッドのオブジェクトのC++デストラクタを実行するように見えるため、シグナルの使用を避けたいと思います。これは私にとって重要です。

4

1 に答える 1

2

実際にキャンセルを行わなければならない場合がありますpthread_setcanceltype()(以下のソースを参照)。だから、これが理由pthread_setcanceltype_for_thread()です。実際のキャンセル タイプは pthread 構造体のフィールドであり、アトミックに変更する必要があります。

ftp://sources.redhat.com/pub/glibc/snapshots/glibc-latest.tar.bz2/glibc-20090518/nptl/pthread_setcanceltype.c

__pthread_setcanceltype (type, oldtype)
     int type;
     int *oldtype;
{
  volatile struct pthread *self;

  self = THREAD_SELF;

  int oldval = THREAD_GETMEM (self, cancelhandling);
  while (1)
    {
      int newval = (type == PTHREAD_CANCEL_ASYNCHRONOUS
                    ? oldval | CANCELTYPE_BITMASK
                    : oldval & ~CANCELTYPE_BITMASK);

      /* Store the old value.  */
      if (oldtype != NULL)
        *oldtype = ((oldval & CANCELTYPE_BITMASK)
                    ? PTHREAD_CANCEL_ASYNCHRONOUS : PTHREAD_CANCEL_DEFERRED);

      /* Update the cancel handling word.  This has to be done
         atomically since other bits could be modified as well.  */
      int curval = THREAD_ATOMIC_CMPXCHG_VAL (self, cancelhandling, newval,
                                              oldval);
      if (__builtin_expect (curval == oldval, 1))
        {
          if (CANCEL_ENABLED_AND_CANCELED_AND_ASYNCHRONOUS (newval))
            {
              THREAD_SETMEM (self, result, PTHREAD_CANCELED);
              __do_cancel ();  // HERE THE CANCELLING
            }

          break;
        }

      /* Prepare for the next round.  */
      oldval = curval;
    }

  return 0;
}
strong_alias (__pthread_setcanceltype, pthread_setcanceltype)

canceltype を外部で変更する大きな必要がある場合は、ライブラリをハックしてフィールドを直接設定できます。

PS: NPTL (Linux の glibc での pthread の現在の実装) の場合、int pthread_t から取得する方法を確認する最も簡単な方法struct pthreadは ... pthread_join です。

 pthread_join (pthread_t threadid, thread_return) 
 { 
     struct pthread *pd = (struct pthread *) threadid;
于 2011-07-06T09:22:44.550 に答える