多线程入门

这里写一个很简单的多线程的入门的程序吧，多线程我还有很长的路要走的呀，这里需要注意的是多线程函数的值的传递

#include <stdio.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>
#include <stdlib.h>
#include <unistd.h>

#define N 5

void *thread_function(void* arg);
pthread_mutex_t mutex;

int count = 100;

int main(int argc, char* argv[])
{
if(argc < 4)
{
printf("Usage : %s infile1 infile2 outdic\n", argv[0]);
exit(-1);
}

int res;
pthread_t a_thread
;
void *thread_result;

res = pthread_mutex_init(&mutex, NULL);
if(res != 0)
{
printf("Mutex init error!\n");
exit(-1);
}

int i = 0;
for(i = 0; i < N; ++ i)
{
res = pthread_create(&a_thread[i], NULL, thread_function, &i);
if(res != 0)
{
printf("Thread create failure!\n");
exit(-1);
}
sleep(1);
}

for(i = 0; i < N; ++ i)
{
res = pthread_join(a_thread[i], &thread_result);
if(res != 0)
{
printf("Thread join failure!\n");
exit(-1);
}
}

printf("Thread join \n");

pthread_mutex_destroy(&mutex);

return 0;

}

void *thread_function(void* arg)
{
int id = *((int*)arg); // Pay Attention the value
while(1)
{
pthread_mutex_lock(&mutex);
if(count > 0)
{
printf("Thread %d Sell the NO %d tickek\n", id + 1, count);
-- count;
}else{
pthread_mutex_unlock(&mutex);
break;
}
pthread_mutex_unlock(&mutex);
sleep(1);
}
}

编译时的命令为：

$ g++ test_selltickets.cpp -o test_selltickets -lpthread