可以用pthread_kill函数
传递信号SIGSTOP挂起
传递SIGCONT 恢复
调用系统的stop挂起
或者用kill -stop 挂起
类似的 用SIGCONT 恢复。
Linux系统pthread_join用于挂起当前线程(调用pthread_join的线程),直到thread指定的线程终止运行为止,当前线程才继续执行。
案例代码:
/********************************************* Name:pthread_join.c
** 用于Linux下多线程学习
** 案例解释线程的暂停和结束
** Author:admin
** Date:2015/8/11
** Copyright (c) 2015,All Rights Reserved!
**********************************************
#include <pthread.h>
#include <unistd.h>
#include <stdio.h>
void *thread(void *str)
{
int i
//不调用pthread_join线程函数
for (i = 0 i < 10 ++i)
{
sleep(2)
printf( "This in the thread : %d\n" , i )
}
return NULL
}
int main()
{
pthread_t pth
int i
int ret = pthread_create(&pth, NULL, thread, (void *)(i))
//调用pthread_join线程函数
pthread_join(pth, NULL)
for (i = 0 i < 10 ++i)
{
sleep(1)
printf( "This in the main : %d\n" , i )
}
return 0
}
通过Linux下shell命令执行上面的案例代码:
[root@localhost src]# gcc pthread_join.c -lpthread[root@localhost src]# ./a.out
This in the main : 0
This in the thread : 0
This in the main : 1
This in the main : 2
This in the thread : 1
This in the main : 3
This in the main : 4
This in the thread : 2
This in the main : 5
This in the main : 6
This in the thread : 3
This in the main : 7
This in the main : 8
This in the thread : 4
This in the main : 9
子线程还没有执行完毕,main函数已经退出,那么子线程也就退出了,“pthread_join(pth, NULL)”函数起作用。
[root@localhost src]# gcc pthread_join.c -lpthread[root@localhost src]# ./a.out
This in the thread : 0
This in the thread : 1
This in the thread : 2
This in the thread : 3
This in the thread : 4
This in the thread : 5
This in the thread : 6
This in the thread : 7
This in the thread : 8
This in the thread : 9
This in the main : 0
This in the main : 1
This in the main : 2
This in the main : 3
This in the main : 4
This in the main : 5
This in the main : 6
This in the main : 7
This in the main : 8
This in the main : 9
这说明pthread_join函数的调用者在等待子线程退出后才继续执行。
大概的介绍一下Linux 的指定CPU运行,包括进程和线程。linux下的top命令是可以查看当前的cpu的运行状态,按1可以查看系统有多少个CPU,以及每个CPU的运行状态。可是如何查看线程的CPU呢?top
-Hp pid,pid就是你当前程序的进程号,如果是多线程的话,是可以查看进程内所有线程的CPU和内存使用情况。
pstree可以查看主次线程,同样的pstree -p pid。可以查看进程的线程情况。
taskset这个其实才是重点,可以查看以及设置当前进程或线程运行的CPU(设置亲和力)。
taskset -pc pid,查看当前进程的cpu,当然有的时候不只是一个,taskset -pc cpu_num pid ,cpu_num就是设置的cpu。
这样的话基本的命令和 *** 作其实大家都知道了,接下来就是在代码中完成这些 *** 作,并通过命令去验证代码的成功率。
进程制定CPU运行:
[cpp] view plain copy
#include<stdlib.h>
#include<stdio.h>
#include<sys/types.h>
#include<sys/sysinfo.h>
#include<unistd.h>
#define __USE_GNU
#include<sched.h>
#include<ctype.h>
#include<string.h>
int main(int argc, char* argv[])
{
//sysconf获取有几个CPU
int num = sysconf(_SC_NPROCESSORS_CONF)
int created_thread = 0
int myid
int i
int j = 0
//原理其实很简单,就是通过cpu_set_t进行位与 *** 作
cpu_set_t mask
cpu_set_t get
if (argc != 2)
{
printf("usage : ./cpu num\n")
exit(1)
}
myid = atoi(argv[1])
printf("system has %i processor(s). \n", num)
//先进行清空,然后设置掩码
CPU_ZERO(&mask)
CPU_SET(myid, &mask)
//设置进程的亲和力
if (sched_setaffinity(0, sizeof(mask), &mask) == -1)
{
printf("warning: could not set CPU affinity, continuing...\n")
}
while (1)
{
CPU_ZERO(&get)
//获取当前进程的亲和力
if (sched_getaffinity(0, sizeof(get), &get) == -1)
{
printf("warning: cound not get cpu affinity, continuing...\n")
}
for (i = 0i <numi++)
{
if (CPU_ISSET(i, &get))
{
printf("this process %d is running processor : %d\n",getpid(), i)
}
}
}
return 0
}
进程设置CPU运行,其实只能是单线程。多线程设定CPU如下:
[cpp] view plain copy
#define _GNU_SOURCE
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <sched.h>
void *myfun(void *arg)
{
cpu_set_t mask
cpu_set_t get
char buf[256]
int i
int j
//同样的先去获取CPU的个数
int num = sysconf(_SC_NPROCESSORS_CONF)
printf("system has %d processor(s)\n", num)
for (i = 0i <numi++) {
CPU_ZERO(&mask)
CPU_SET(i, &mask)
//这个其实和设置进程的亲和力基本是一样的
if (pthread_setaffinity_np(pthread_self(), sizeof(mask), &mask) <0) {
fprintf(stderr, "set thread affinity failed\n")
}
CPU_ZERO(&get)
if (pthread_getaffinity_np(pthread_self(), sizeof(get), &get) <0) {
fprintf(stderr, "get thread affinity failed\n")
}
for (j = 0j <numj++)
{
if (CPU_ISSET(j, &get))
{
printf("thread %d is running in processor %d\n", (int)pthread_self(), j)
}
}
j = 0
while (j++ <100000000) {
memset(buf, 0, sizeof(buf))
}
}
pthread_exit(NULL)
}
int main(int argc, char *argv[])
{
pthread_t tid
if (pthread_create(&tid, NULL, (void *)myfun, NULL) != 0)
{
fprintf(stderr, "thread create failed\n")
return -1
}
pthread_join(tid, NULL)
return 0
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)