Потоки pthread

for(int i=0;i<4;i++)
  pthread_create(&t[i],NULL,worker,&i);

int rc=pthread_create(&t,NULL,worker,arg);
if(rc) fprintf(stderr,"%s\n",strerror(rc));

void *worker(void *p){
  int result=42;
  return &result;
}

void *result=NULL;
int rc=pthread_join(t,&result);

for(size_t i=0;i<5;i++){
  int rc=pthread_create(&t[i],NULL,worker,&ctx[i]);
  if(rc){ created=i; goto rollback; }
}

/* два потока */
for(int i=0;i<100000;i++) counter++;

/* T1 */ lock(A); lock(B);
/* T2 */ lock(B); lock(A);

if(shared.ready) use(shared.value); /* чтение без m */

pthread_mutex_lock(&m);
send(sock,shared.buf,shared.len,0);
pthread_mutex_unlock(&m);

int rc=pthread_mutex_lock(&m);
if(rc!=0) return rc;

pthread_mutex_lock(&m);
while(queue_empty())
  pthread_cond_wait(&cv,&m);
item=pop();
pthread_mutex_unlock(&m);

pthread_mutex_lock(&m);
bool need_wait = !ready;
pthread_mutex_unlock(&m);

/* pthread_cond_signal(&cv) может выполниться здесь. */

if (need_wait) {
    pthread_mutex_lock(&m);
    pthread_cond_wait(&cv, &m);
    pthread_mutex_unlock(&m);
}

pthread_t t;
pthread_create(&t,NULL,worker,NULL);
/* ни pthread_join, ни pthread_detach */

pthread_mutex_lock(&m);
shutdown=true;
pthread_cond_broadcast(&cv);
pthread_mutex_unlock(&m);

void *p = NULL;
pthread_join(t, &p);
consume(p);
/* кто завершает владение объектом p? */

static int counter;

void *worker(void *arg) {
    (void)arg;
    ++counter;
    return NULL;
}
/* два потока одновременно выполняют worker */

for i in $(seq 1 1000); do ./race_test || break; done

shared.data=42;
ready=true; /* volatile */