73 lines
1.5 KiB
C
73 lines
1.5 KiB
C
|
/* cpu-reordering.c */
|
|||
|
|
|
|||
|
|
#include <pthread.h>
|
|||
|
|
#include <semaphore.h>
|
|||
|
|
#include <stdio.h>
|
|||
|
|
#include <inttypes.h>
|
|||
|
|
#include <stdint.h>
|
|||
|
|
#include <stdlib.h>
|
|||
|
|
#include <time.h>
|
|||
|
|
/*
|
|||
|
|
* В этом коде происходит та же логика, что и в примере ранее.
|
|||
|
|
Семафоры используются чтобы при каждом запуске итерации
|
|||
|
|
в thread0_impl/thread1_impl в момент sem_post потоки
|
|||
|
|
подождали друг друга.
|
|||
|
|
*/
|
|||
|
|
sem_t sem_begin0, sem_begin1, sem_end;
|
|||
|
|
|
|||
|
|
int x, y, read0, read1;
|
|||
|
|
|
|||
|
|
void *thread0_impl( void *param )
|
|||
|
|
{
|
|||
|
|
for (;;) {
|
|||
|
|
sem_wait( &sem_begin0 );
|
|||
|
|
|
|||
|
|
x = 1;
|
|||
|
|
read0 = y;
|
|||
|
|
|
|||
|
|
sem_post( &sem_end );
|
|||
|
|
}
|
|||
|
|
return NULL;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
void *thread1_impl( void *param )
|
|||
|
|
{
|
|||
|
|
for (;;) {
|
|||
|
|
sem_wait( &sem_begin1 );
|
|||
|
|
|
|||
|
|
y = 1;
|
|||
|
|
read1 = x;
|
|||
|
|
|
|||
|
|
sem_post( &sem_end );
|
|||
|
|
}
|
|||
|
|
return NULL;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
int main( void ) {
|
|||
|
|
sem_init( &sem_begin0, 0, 0);
|
|||
|
|
sem_init( &sem_begin1, 0, 0);
|
|||
|
|
sem_init( &sem_end, 0, 0);
|
|||
|
|
|
|||
|
|
pthread_t thread0, thread1;
|
|||
|
|
pthread_create( &thread0, NULL, thread0_impl, NULL);
|
|||
|
|
pthread_create( &thread1, NULL, thread1_impl, NULL);
|
|||
|
|
|
|||
|
|
for (uint64_t i = 0; i < 1000000; i++)
|
|||
|
|
{
|
|||
|
|
x = 0;
|
|||
|
|
y = 0;
|
|||
|
|
sem_post( &sem_begin0 );
|
|||
|
|
sem_post( &sem_begin1 );
|
|||
|
|
|
|||
|
|
sem_wait( &sem_end );
|
|||
|
|
sem_wait( &sem_end );
|
|||
|
|
|
|||
|
|
if (read0 == 0 && read1 == 0 ) {
|
|||
|
|
printf( "reordering happened on iteration %" PRIu64 "\n", i );
|
|||
|
|
exit(0);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
puts("No reordering detected during 1000000 iterations");
|
|||
|
|
return 0;
|
|||
|
|
}
|