線程的創(chuàng)建和調(diào)度
1退客、線程的創(chuàng)建
pthread_create創(chuàng)建線程
#include <pthread.h>
int pthread_create(pthread_t *thread, const pthread_attr_t *attr,
void *(*start_routine) (void *), void *arg);
參數(shù)：
- pthread_t *thread 指定創(chuàng)建線程id
- const pthread_attr_t *attr；NULL
- void (start_routine) (void *)： 線程函數(shù)
- void *arg:線程參數(shù)
返回值：成功，返回0,；出錯(cuò)，返回錯(cuò)誤值；
2、等待線程的返回值
pthread_join();等待線程返回值
#include <pthread.h>
int pthread_join(pthread_t thread, void **retval);
參數(shù)：
- pthread_t thread ：線程ID號(hào)
- void **retval：線程返回結(jié)果
返回值：成功卒暂，返回0；失敗娄帖，返回錯(cuò)誤號(hào)也祠；
3、獲取線程自身線程ID
pthread_self();
#include <pthread.h>
pthread_t pthread_self(void);
參數(shù)：無(wú)
返回值：自身線程ID近速；
4诈嘿、判斷線程是否為同一個(gè)線程
pthread_equal()
#include <pthread.h>
int pthread_equal(pthread_t t1, pthread_t t2);
參數(shù)：
- 線程1的ID
- 線程2的ID
返回值：相同，返回非0削葱；不相同奖亚，返回0；
5析砸、取消指定線程
pthread_cancel();
#include <pthread.h>
int pthread_cancel(pthread_t thread);
參數(shù)：線程ID號(hào)
返回值：成功昔字，返回0；失敗，返回非0作郭；
#include <stdio.h>
#include <pthread.h>
// 線程函數(shù)：用于提供線程的執(zhí)行指令代碼
void *thread_func1(void *arg);
void *thread_func2(void *arg);
int main(int argc, char *argv[])
{
pthread_t thread_id1;
pthread_t thread_id2;
// 創(chuàng)建線程并指定線程的執(zhí)行函數(shù)
pthread_create(&thread_id1, NULL, thread_func1, NULL);
pthread_create(&thread_id2, NULL, thread_func2, NULL);
// 等待指定線程的退出
// 注意：主線程退出陨囊，則進(jìn)程退出，該進(jìn)程下的相關(guān)線程全部退出
pthread_join(thread_id1, NULL);
pthread_join(thread_id2, NULL);
return 0;
}
void *thread_func1(void *arg)
{
while(1)
printf("A");
pthread_exit(NULL);
}
void *thread_func2(void *arg)
{
while(1)
printf("B");
pthread_exit(NULL);
}
//使用雙線程求解1~100的和
#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
#include <stdlib.h>
// 定義傳遞個(gè)線程的參數(shù)結(jié)構(gòu)類型
struct thread_arg
{
int thread_no; // 線程編號(hào)(自定義的)
int lower; // 區(qū)間下限
int upper; // 區(qū)間上限
// int sum; // 傳出結(jié)果方法2夹攒，可以用作接收線程計(jì)算完畢后返回的整數(shù)結(jié)果
};
// 定義用于傳遞線程參數(shù)使用的全部變量蜘醋，每一個(gè)線程一個(gè)
struct thread_arg argument1, argument2;
// 線程函數(shù)：用于提供線程執(zhí)行的指令代碼
void *add_thread_func(void *arg);
int main(int argc, char *argv[])
{
pthread_t thread_id1;
pthread_t thread_id2;
// 定義指向線程返回結(jié)果空間的地址
int *psum1 = NULL;
int *psum2 = NULL;
// 創(chuàng)建線程1
argument1.thread_no = 1;
argument1.lower = 1;
argument1.upper = 50;
pthread_create(&thread_id1, NULL, add_thread_func, &argument1);
// 創(chuàng)建線程2
argument2.thread_no = 2;
argument2.lower = 51;
argument2.upper = 100;
pthread_create(&thread_id2, NULL, add_thread_func, &argument2);
// 等待線程的退出，并接收線程返回值
pthread_join(thread_id1, &psum1);
pthread_join(thread_id2, &psum2);
printf("sum = %d\n", *psum1+*psum2);
// 釋放從線程中得到的結(jié)果空間
free(psum1);
free(psum2);
return 0;
}
// 線程函數(shù)
void *add_thread_func(void *arg)
{
struct thread_arg *p_arg = (struct thread_arg *)arg;
int i = 0;
int sum = 0;
int *p_res = NULL;
// 累和
for(i = p_arg->lower; i < p_arg->upper+1; i++)
sum += i;
//printf("in thread no %d : sum = %d\n", p_arg->thread_no, sum);
// 開辟空間存放結(jié)果
p_res = (int *)malloc(sizeof(int));
*p_res = sum;
// 返回結(jié)果方法2咏尝，使用線程參數(shù)使用的全局變量返回
//p_arg->sum = sum;
// 線程返回結(jié)果并退出
pthread_exit(p_res);
}
