0

これは、この質問のフォローアップです。

そのコードでは、fflush(stdout)出力を使用していないときに、保持したときに出力が画面にフラッシュされませんでしたsleep(1)。

#define S sleep(0)

void* xThread_fn(void* arg)
{
while(1)
    {
    S;
    pthread_mutex_lock(&read_c_mutex);
        if(!read_c)
        {
            pthread_mutex_unlock(&read_c_mutex);
            printf(" X");
        }
        else
        {
            pthread_mutex_unlock(&read_c_mutex);
            pthread_exit(NULL);
        }
    fflush(stdout); <---THIS ONE HERE
    }

}

しかし、sleep(0)必要がない場合fflush(stdout)、出力は適切に更新されstdoutます。これはなぜですか？

Q1. sleep(0)出力がフラッシュされる方法が変更される原因となるのはなぜですか?

コードを次のように変更すると (実行を追跡するため)、

#define S sleep(1)

int read_c = 0;
pthread_mutex_t read_c_mutex = PTHREAD_MUTEX_INITIALIZER;

void* inputThread_fn(void* arg)
{
printf("%p is Input\n",pthread_self());
char inputChar;
int i = 0;
while(1)
{
    S;
    printf("\nChecking input");
    scanf("%c",&inputChar);
    if(inputChar=='C' || inputChar == 'c')
    {
     pthread_mutex_trylock(&read_c_mutex);
     printf("%p has lock %d\n",pthread_self(),i);
     read_c = 1;
     pthread_mutex_unlock(&read_c_mutex);       
     printf("%p has UNlockED %d\n",pthread_self(),i++);
     printf("%p is Gone!\n",pthread_self());
     fflush(stdout);
     pthread_exit(NULL);
    }
}
}

void* xThread_fn(void* arg)
{
    int i = 0;
    printf("%p is X\n",pthread_self());
    while(1)
    {
     S;
     printf("X trying for a lock\n");
     pthread_mutex_trylock(&read_c_mutex);
     printf("%p has lock %d\n",pthread_self(),i);
     if(!read_c)
     {
      pthread_mutex_unlock(&read_c_mutex);
      printf("%p has UNlockED %d\n",pthread_self(),i++);
      printf("X\n");
      fflush(stdout);
     } 
     else
     {
      printf("%p is Gone!\n",pthread_self());   
      pthread_mutex_unlock(&read_c_mutex);
      fflush(stdout);
      pthread_exit(NULL);
     }
    }
}

void* yThread_fn(void* arg)
{
 printf("%p is Y\n",pthread_self());
 int i = 0;
 while(1)
 {
  S;
  printf("Y trying for a lock\n");
  pthread_mutex_trylock(&read_c_mutex);
  printf("%p has lock %d\n",pthread_self(),i);
  if(!read_c)
  {
   pthread_mutex_unlock(&read_c_mutex);
   printf("%p has UNlockED %d\n",pthread_self(),i++);
   printf("Z\n");
   fflush(stdout);
  }
  else
  {
    printf("%p is Gone!\n",pthread_self());
    pthread_mutex_unlock(&read_c_mutex);
    fflush(stdout);
    pthread_exit(NULL);
   }
  }
}

サンプル出力は

0xb6700b70 is Input
0xb6f01b70 is Y
0xb7702b70 is X

Checking inputY trying for a lock
0xb6f01b70 has lock 0
0xb6f01b70 has UNlockED 0
Z
X trying for a lock
0xb7702b70 has lock 0
0xb7702b70 has UNlockED 0
X
Y trying for a lock
0xb6f01b70 has lock 1
0xb6f01b70 has UNlockED 1
Z
X trying for a lock
0xb7702b70 has lock 1
0xb7702b70 has UNlockED 1
X
Y trying for a lock
0xb6f01b70 has lock 2
0xb6f01b70 has UNlockED 2
Z
X trying for a lock
0xb7702b70 has lock 2
0xb7702b70 has UNlockED 2
X
Y trying for a lock
0xb6f01b70 has lock 3
0xb6f01b70 has UNlockED 3
Z
X trying for a lock
0xb7702b70 has lock 3
0xb7702b70 has UNlockED 3
X
Y trying for a lock
0xb6f01b70 has lock 4
0xb6f01b70 has UNlockED 4
Z
X trying for a lock
0xb7702b70 has lock 4
0xb7702b70 has UNlockED 4
X
c
Y trying for a lock
0xb6f01b70 has lock 5
0xb6f01b70 has UNlockED 5
Z
X trying for a lock
0xb7702b70 has lock 5
0xb7702b70 has UNlockED 5
X
0xb6700b70 has lock 0
0xb6700b70 has UNlockED 0
0xb6700b70 is Gone!
Y trying for a lock
0xb6f01b70 has lock 6
0xb6f01b70 is Gone!
X trying for a lock
0xb7702b70 has lock 6
0xb7702b70 is Gone!

Q2. pthread_mutex_trylock()の値をチェックするためにロックを取得するまでコードを while ループで処理したかったため、 を使用しましたread_c。で同じことが達成されるようpthread_mutex_lock();です。それは私をもっと混乱させます。pthread_mutex_trylock(); tooの場合、出力は常に次のようになりますか? 1 のX後に 1 が続きZます。次のような状況はありませんかX X Z X(OS によってスレッドが切り替えられ、ythread がロックを試みて失敗した場合)。

4

2 に答える 2

4

「トライロック」の質問に答えます。

pthread_mutex_trylockミューテックスのロックのみを試みます。他の誰かがミューテックスをロックしている場合、エラーを返し、実行を続けます。戻り値をチェックしていないため、ミューテックスを保持せずに、ミューテックスによって保護されているデータに触れる可能性があります。

あなたのコードは、ミューテックスをまったく持たないのと同じです。

pthread_mutex_trylock非常に特別な理由でロックを待つことができず、ミューテックスの取得に失敗したときに別の動作にフォールバックする状況でのみ使用する必要があります。戻り値をチェックせずに呼び出すと、常にバグになります。

完全に正しくするには、戻り値pthread_mutex_lockも確認する必要があります。しかし、ほとんどの場合、それを行わなくても問題を解決できます。trylock の戻り値をチェックしないと、決して逃げることはできません。

于 2013-04-05T11:51:38.763 に答える