关于linux的进程和线程

关于linux的进程和线程

http://kenby.iteye.com/blog/1014039

Linux下的多线程编程

http://fanqiang.chinaunix.net/a4/b8/20010811/0905001105.html


  线程的最大特点是资源的共享性,但资源共享中的同步问题是多线程编程的难点。linux下提供了多种方式来处理线程同步,最常用的是互斥锁、条件变量和信号量。

  1)互斥锁(mutex)

  通过锁机制实现线程间的同步。同一时刻只允许一个线程执行一个关键部分的代码。

  int pthread_mutex_init(pthread_mutex_t *mutex,const pthread_mutex_attr_t *mutexattr);

  int pthread_mutex_lock(pthread_mutex *mutex);

  int pthread_mutex_destroy(pthread_mutex *mutex);

  int pthread_mutex_unlock(pthread_mutex *

  (1)先初始化锁init()或静态赋值pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIER

  attr_t有:

  PTHREAD_MUTEX_TIMED_NP:其余线程等待队列

  PTHREAD_MUTEX_RECURSIVE_NP:嵌套锁,允许线程多次加锁,不同线程,解锁后重新竞争

  PTHREAD_MUTEX_ERRORCHECK_NP:检错,与一同,线程请求已用锁,返回EDEADLK;

  PTHREAD_MUTEX_ADAPTIVE_NP:适应锁,解锁后重新竞争

  (2)加锁,lock,trylock,lock阻塞等待锁,trylock立即返回EBUSY

  (3)解锁,unlock需满足是加锁状态,且由加锁线程解锁

  (4)清除锁,destroy(此时锁必需unlock,否则返回EBUSY,//Linux下互斥锁不占用内存资源

  示例代码

  #include <cstdio>

  #include <cstdlib>

  #include <unistd.h>

  #include <pthread.h>

  #include "iostream"

  using namespace std;

  pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

  int tmp;

  void* thread(void *arg)

  {

  cout << "thread id is " << pthread_self() << endl;

  pthread_mutex_lock(&mutex);

  tmp = 12;

  cout << "Now a is " << tmp << endl;

  pthread_mutex_unlock(&mutex);

  return NULL;

  }

  int main()

  {

  pthread_t id;

  cout << "main thread id is " << pthread_self() << endl;

  tmp = 3;

  cout << "In main func tmp = " << tmp << endl;

  if (!pthread_create(&id, NULL, thread, NULL))

  {

  cout << "Create thread success!" << endl;

  }

  else

  {

  cout << "Create thread failed!" << endl;

  }

  pthread_join(id, NULL);

  pthread_mutex_destroy(&mutex);

  return 0;

  }

  编译: g++ -o thread testthread.cpp -lpthread

  说明:pthread库不是Linux系统默认的库,连接时需要使用静态库libpthread.a,所以在使用pthread_create()创建线程,以及调用pthread_atfork()函数建立fork处理程序时,需要链接该库。在编译中要加 -lpthread参数。

  2)条件变量(cond)

  利用线程间共享的全局变量进行同步的一种机制。条件变量上的基本操作有:触发条件(当条件变为 true 时);等待条件,挂起线程直到其他线程触发条件。

  int pthread_cond_init(pthread_cond_t *cond,pthread_condattr_t *cond_attr);

  int pthread_cond_wait(pthread_cond_t *cond,pthread_mutex_t *mutex);

  int pthread_cond_timewait(pthread_cond_t *cond,pthread_mutex *mutex,const timespec *abstime);

  int pthread_cond_destroy(pthread_cond_t *cond);

  int pthread_cond_signal(pthread_cond_t *cond);

  int pthread_cond_broadcast(pthread_cond_t *cond); //解除所有线程的阻塞

  (1)初始化.init()或者pthread_cond_t cond=PTHREAD_COND_INITIALIER(前者为动态初始化,后者为静态初始化);属性置为NULL

  (2)等待条件成立.pthread_wait,pthread_timewait.wait()释放锁,并阻塞等待条件变量为真,timewait()设置等待时间,仍未signal,返回ETIMEOUT(加锁保证只有一个线程wait)

  (3)激活条件变量:pthread_cond_signal,pthread_cond_broadcast(激活所有等待线程)

  (4)清除条件变量:destroy;无线程等待,否则返回EBUSY

  对于

  int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex);

  int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex, const struct timespec *abstime);

  一定要在mutex的锁定区域内使用。

  如果要正确的使用pthread_mutex_lock与pthread_mutex_unlock,请参考

  pthread_cleanup_push和pthread_cleanup_pop宏,它能够在线程被cancel的时候正确的释放mutex!

  另外,posix1标准说,pthread_cond_signal与pthread_cond_broadcast无需考虑调用线程是否是mutex的拥有者,也就是说,可以在lock与unlock以外的区域调用。如果我们对调用行为不关心,那么请在lock区域之外调用吧。

  说明:

  (1)pthread_cond_wait 自动解锁互斥量(如同执行了pthread_unlock_mutex),并等待条件变量触发。这时线程挂起,不占用CPU时间,直到条件变量被触发(变量为ture)。在调用 pthread_cond_wait之前,应用程序必须加锁互斥量。pthread_cond_wait函数返回前,自动重新对互斥量加锁(如同执行了pthread_lock_mutex)。

  (2)互斥量的解锁和在条件变量上挂起都是自动进行的。因此,在条件变量被触发前,如果所有的线程都要对互斥量加锁,这种机制可保证在线程加锁互斥量和进入等待条件变量期间,条件变量不被触发。条件变量要和互斥量相联结,以避免出现条件竞争——个线程预备等待一个条件变量,当它在真正进入等待之前,另一个线程恰好触发了该条件(条件满足信号有可能在测试条件和调用pthread_cond_wait函数(block)之间被发出,从而造成无限制的等待)。

  (3)pthread_cond_timedwait 和 pthread_cond_wait 一样,自动解锁互斥量及等待条件变量,但它还限定了等待时间。如果在abstime指定的时间内cond未触发,互斥量mutex被重新加锁,且pthread_cond_timedwait返回错误 ETIMEDOUT。abstime 参数指定一个绝对时间,时间原点与 time 和 gettimeofday 相同:abstime = 0 表示 1970年1月1日00:00:00 GMT。

  (4)pthread_cond_destroy 销毁一个条件变量,释放它拥有的资源。进入 pthread_cond_destroy 之前,必须没有在该条件变量上等待的线程。

  (5)条件变量函数不是异步信号安全的,不应当在信号处理程序中进行调用。特别要注意,如果在信号处理程序中调用 pthread_cond_signal 或 pthread_cond_boardcast 函数,可能导致调用线程死锁。

  示例程序1

  #include <stdio.h>

  #include <pthread.h>

  #include "stdlib.h"

  #include "unistd.h"

  pthread_mutex_t mutex;

  pthread_cond_t cond;

  void hander(void *arg)

  {

  free(arg);

  (void)pthread_mutex_unlock(&mutex);

  }

  void *thread1(void *arg)

  {

  pthread_cleanup_push(hander, &mutex);

  while(1)

  {

  printf("thread1 is running\n");

  pthread_mutex_lock(&mutex);

  pthread_cond_wait(&cond,&mutex);

  printf("thread1 applied the condition\n");

  pthread_mutex_unlock(&mutex);

  sleep(4);

  }

  pthread_cleanup_pop(0);

  }

  void *thread2(void *arg)

  {

  while(1)

  {

  printf("thread2 is running\n");

  pthread_mutex_lock(&mutex);

  pthread_cond_wait(&cond,&mutex);

  printf("thread2 applied the condition\n");

  pthread_mutex_unlock(&mutex);

  sleep(1);

  }

  }

  int main()

  {

  pthread_t thid1,thid2;

  printf("condition variable study!\n");

  pthread_mutex_init(&mutex,NULL);

  pthread_cond_init(&cond,NULL);

  pthread_create(&thid1,NULL,thread1,NULL);

  pthread_create(&thid2,NULL,thread2,NULL);

  sleep(1);

  do

  {

  pthread_cond_signal(&cond);

  }while(1);

  sleep(20);

  pthread_exit(0);

  return 0;

  }

  示例程序2:

  #include <pthread.h>

  #include <unistd.h>

  #include "stdio.h"

  #include "stdlib.h"

  static pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER;

  static pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

  struct node

  {

  int n_number;

  struct node *n_next;

  } *head = NULL;

  

  static void cleanup_handler(void *arg)

  {

  printf("Cleanup handler of second thread./n");

  free(arg);

  (void)pthread_mutex_unlock(&mtx);

  }

  static void *thread_func(void *arg)

  {

  struct node *p = NULL;

  pthread_cleanup_push(cleanup_handler, p);

  while (1)

  {

  //这个mutex主要是用来保证pthread_cond_wait的并发性

  pthread_mutex_lock(&mtx);

  while (head == NULL)

  {

  //这个while要特别说明一下,单个pthread_cond_wait功能很完善,为何

  //这里要有一个while (head == NULL)呢?因为pthread_cond_wait里的线

  //程可能会被意外唤醒,如果这个时候head != NULL,则不是我们想要的情况。

  //这个时候,应该让线程继续进入pthread_cond_wait

  // pthread_cond_wait会先解除之前的pthread_mutex_lock锁定的mtx,

  //然后阻塞在等待对列里休眠,直到再次被唤醒(大多数情况下是等待的条件成立

  //而被唤醒,唤醒后,该进程会先锁定先pthread_mutex_lock(&mtx);,再读取资源

  //用这个流程是比较清楚的

  pthread_cond_wait(&cond, &mtx);

  p = head;

  head = head->n_next;

  printf("Got %d from front of queue/n", p->n_number);

  free(p);

  }

  pthread_mutex_unlock(&mtx); //临界区数据操作完毕,释放互斥锁

  }

  pthread_cleanup_pop(0);

  return 0;

  }

  int main(void)

  {

  pthread_t tid;

  int i;

  struct node *p;

  //子线程会一直等待资源,类似生产者和消费者,但是这里的消费者可以是多个消费者,而

  //不仅仅支持普通的单个消费者,这个模型虽然简单,但是很强大

  pthread_create(&tid, NULL, thread_func, NULL);

  sleep(1);

  for (i = 0; i < 10; i++)

  {

  p = (struct node*)malloc(sizeof(struct node));

  p->n_number = i;

  pthread_mutex_lock(&mtx); //需要操作head这个临界资源,先加锁,

  p->n_next = head;

  head = p;

  pthread_cond_signal(&cond);

  pthread_mutex_unlock(&mtx); //解锁

  sleep(1);

  }

  printf("thread 1 wanna end the line.So cancel thread 2./n");

  //关于pthread_cancel,有一点额外的说明,它是从外部终止子线程,子线程会在最近的取消点,退出

  //线程,而在我们的代码里,最近的取消点肯定就是pthread_cond_wait()了。

  pthread_cancel(tid);

  pthread_join(tid, NULL);

  printf("All done -- exiting/n");

  return 0;

  }

  3)信号量

  如同进程一样,线程也可以通过信号量来实现通信,虽然是轻量级的。

  信号量函数的名字都以"sem_"打头。线程使用的基本信号量函数有四个。

  #include <semaphore.h>

  int sem_init (sem_t *sem , int pshared, unsigned int value);

  这是对由sem指定的信号量进行初始化,设置好它的共享选项(linux 只支持为0,即表示它是当前进程的局部信号量),然后给它一个初始值VALUE。

  两个原子操作函数:

  int sem_wait(sem_t *sem);

  int sem_post(sem_t *sem);

  这两个函数都要用一个由sem_init调用初始化的信号量对象的指针做参数。

  sem_post:给信号量的值加1;

  sem_wait:给信号量减1;对一个值为0的信号量调用sem_wait,这个函数将会等待直到有其它线程使它不再是0为止。

  int sem_destroy(sem_t *sem);

  这个函数的作用是再我们用完信号量后都它进行清理。归还自己占有的一切资源。

  示例代码:

  #include <stdlib.h>

  #include <stdio.h>

  #include <unistd.h>

  #include <pthread.h>

  #include <semaphore.h>

  #include <errno.h>

  #define return_if_fail(p) if((p) == 0){printf ("[%s]:func error!/n", __func__);return;}

  typedef struct _PrivInfo

  {

  sem_t s1;

  sem_t s2;

  time_t end_time;

  }PrivInfo;

  static void info_init (PrivInfo* thiz);

  static void info_destroy (PrivInfo* thiz);

  static void* pthread_func_1 (PrivInfo* thiz);

  static void* pthread_func_2 (PrivInfo* thiz);

  int main (int argc, char** argv)

  {

  pthread_t pt_1 = 0;

  pthread_t pt_2 = 0;

  int ret = 0;

  PrivInfo* thiz = NULL;

  thiz = (PrivInfo* )malloc (sizeof (PrivInfo));

  if (thiz == NULL)

  {

  printf ("[%s]: Failed to malloc priv./n");

  return -1;

  }

  info_init (thiz);

  ret = pthread_create (&pt_1, NULL, (void*)pthread_func_1, thiz);

  if (ret != 0)

  {

  perror ("pthread_1_create:");

  }

  ret = pthread_create (&pt_2, NULL, (void*)pthread_func_2, thiz);

  if (ret != 0)

  {

  perror ("pthread_2_create:");

  }

  pthread_join (pt_1, NULL);

  pthread_join (pt_2, NULL);

  info_destroy (thiz);

  return 0;

  }

  static void info_init (PrivInfo* thiz)

  {

  return_if_fail (thiz != NULL);

  thiz->end_time = time(NULL) + 10;

  sem_init (&thiz->s1, 0, 1);

  sem_init (&thiz->s2, 0, 0);

  return;

  }

  static void info_destroy (PrivInfo* thiz)

  {

  return_if_fail (thiz != NULL);

  sem_destroy (&thiz->s1);

  sem_destroy (&thiz->s2);

  free (thiz);

  thiz = NULL;

  return;

  }

  static void* pthread_func_1 (PrivInfo* thiz)

  {

  return_if_fail (thiz != NULL);

  while (time(NULL) < thiz->end_time)

  {

  sem_wait (&thiz->s2);

  printf ("pthread1: pthread1 get the lock./n");

  sem_post (&thiz->s1);

  printf ("pthread1: pthread1 unlock/n");

  sleep (1);

  }

  return;

  }

  static void* pthread_func_2 (PrivInfo* thiz)

  {

  return_if_fail (thiz != NULL);

  while (time (NULL) < thiz->end_time)

  {

  sem_wait (&thiz->s1);

  printf ("pthread2: pthread2 get the unlock./n");

  sem_post (&thiz->s2);

  printf ("pthread2: pthread2 unlock./n");

  sleep (1);

  }

  return;

  }

  通过执行结果后,可以看出,会先执行线程二的函数,然后再执行线程一的函数。它们两就实现了同步。在上大学的时候,虽然对这些概念知道,可都没有实践过,所以有时候时间一久就会模糊甚至忘记,到了工作如果还保持这么一种状态,那就太可怕了。虽然现在外面的技术在不断的变化更新,可是不管怎么变,其核心技术还是依旧的,所以我们必须要打好自己的基础,再学习其他新的知识,那时候再学新的知识也会觉得比较简单的。信号量代码摘自http://blog.csdn.net/wtz1985/article/details/

  参考:

  【1】 http://www.cnblogs.com/feisky/archive/2009/11/12/.html

  【2】 http://www.cnblogs.com/mydomain/archive/2011/07/10/.html

  【3】 线程函数介绍

  http://www.unix.org/version2/whatsnew/threadsref.html

  【4】 http://www.yolinux.com/TUTORIALS/LinuxTutorialPosixThreads.html

  【5】 线程常用函数简介

  http://www.rosoo.net/a//8954.html

  【6】 条件变量

  http://blog.csdn.net/hiflower/article/details/

  【7】条件变量函数说明

  http://blog.csdn.net/hairetz/article/details/

  本文来自博文:

  http://www.cnblogs.com/mydomain/archive/2011/08/14/.html

  文章出处:飞诺网(www.diybl.com):http://www.diybl.com/course/6_system/linux/linuxjq//.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/508711.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

linux setsockopt函数

功能描述&#xff1a; 获取或者设置与某个套接字关联的选 项。选项可能存在于多层协议中&#xff0c;它们总会出现在最上面的套接字层。当操作套接字选项时&#xff0c;选项位于的层和选项的名称必须给出。为了操作套接字层的选项&#xff0c;应该 将层的值指定为SOL_S…

struct linger

Linux下tcp连接断开的时候调用close()函数&#xff0c;有优雅断开和强制断开两种方式。那么如何设置断开连接的方式呢&#xff1f;是通过设置socket描述符一个linger结构体属性。linger结构体数据结构如下&#xff1a; #include <arpa/inet.h>struct linger {int l_onoff…

几种常见的排序算法

冒泡排序 冒泡排序算法的运作如下: 1、比较相邻的元素。如果第一个比第二个大&#xff0c;就交换他们两个。 2、对每一对相邻元素作同样的工作&#xff0c;从开始第一对到结尾的最后一对。这步做完后&#xff0c;最后的元素会是最大的数。 3、针对所有的元素重复以上的步骤…

linux下调试工具的应用

http://www.ibm.com/developerworks/cn/linux/l-pow-debug/

数据结构--赫夫曼树及其应用

讲解请参考 赫夫曼 ------ 赫夫曼树和赫夫曼编码的存储表示------ typedef struct {unsigned int weight;unsigned int parent,lchild,rchild; }HTNode,*HuffmanTree; typedef char ** HuffmanCode;void HuffmanCoding(HuffmanTree& HT,HuffmanCode & HC,int *w,int …

sqlite C/C++ API

官网&#xff1a;https://sqlite.org/download.html 下载代码安装三步走&#xff1a; ./configure // ./configure --help查看安装参数设置&#xff0c;学习configure的配置&#xff0c;明白安装后include、lib、bin等文件的位置 make make install学习SQL基本语法&#xff0…

线程属性总结

今天面试那哥们问起线程属性&#xff0c;me竟然就说出了一个&#xff0c;囧 学习&#xff1a;http://blog.csdn.net/zsf8701/article/details/7842392 http://blog.csdn.net/jxhnuaa/article/details/3254299 http://blog.sina.com.cn/s/blog_9bd573450101hgdr.html int pthre…

单链表面试经典问题

/************************************************** http://www.cnblogs.com/lifuqing/archive/2011/08/20/List.html http://www.cnblogs.com/wenjiang/p/3310233.html 链表经典问题汇总:http://blog.csdn.net/vividonly/article/details/6673758 链表有关的常见面试题:htt…

Linux SO_KEEPALIVE属性,心跳

对于面向连接的TCP socket,在实际应用中通常都要检测对端是否处于连接中,连接端口分两种情况: 1、连接正常关闭,调用close() shutdown()连接优雅关闭,send与recv立马返回错误,select返回SOCK_ERR; 2、连接的对端异常关闭,比如网络断掉,突然断电. 对于第二种情况,判断连接是否断…

Linux下ARM开发环境搭建

本人的系统环境&#xff1a;Linux ubuntu 3.8.0-35-generic #50-Ubuntu SMP Tue Dec 3 01:25:33 UTC 2013 i686 i686 i686 GNU/Linux 1、安装skyeye sudo apt-get install skyeye s kyeye -h可以看到skyeye的版本号为1.2.5也可以到http://sourceforge.jp/projects/sfnet_skyeye…

cygwin开发环境搭建与apt-cyg的应用

1、Cygwin安装 http://www.cygwin.com/下载安装工具 具体安装过程参照http://jingyan.baidu.com/article/6b97984d83dfe51ca2b0bf0e.html 2、Cygwin一些设置 打开Cygwin终端,右击打开 Options...选项 Text可以设置字体的一些属性,如大小、编码,Locale 选择C, Character set 选择…

CentOS下升级python版本

源码安装python 安装python源码所依赖的工具及依赖的库 yum install -y make gcc gcc-c yum install -y bzip2 bzip2-devel yum install zlib-devel openssl openssl-devel -y yum install -y make xz下载安装python源码 从官方网站或者华为镜像源下载所有需的源码包&#xff0…

linux下confstr与uname函数_获取C库与内核信息

#include <stdio.h> #include <sys/utsname.h> //unameint main(int argc, char **argv[]) {struct utsname u;if (uname(&u) ! -1) {printf("获取当前内核的名称和信息如下\n""sysname:%s\n""nodename:%s\n""release:%s\…

linux下getrlimit与sysconf函数

#include <stdio.h> #include <sys/time.h> #include <sys/resource.h>int main(int argc, char *argv[]) {struct rlimit nofile_rlmt;if (getrlimit(RLIMIT_NOFILE, &nofile_rlmt) ! -1) {printf("获取进程最大能打开的文件描述符个数信息:\n&quo…

Linux下environ环境变量操作函数

#include <stdio.h>int main(int argc,char *argv[],char **envptr) {int i0;for(i0; envptr[i]!NULL; i)printf("%s\n",envptr[i]);return 0; } main函数是程序的入口函数,int main(int argc,char *argv[]); argc是程序参数的个数,argv保存参数 与下边的程…

Linux网络编程--聊天室客户端程序

聊天室客户端程序 #define _GNU_SOURCE 1 #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <assert.h> #include <stdio.h> #include <unistd.h> #include <string.h&…

二叉树学习之二叉查找树

写在前面的话 最近接到几个大学同学研究生毕业不是签华为就是签百度,本人取经得到:操作系统、数据结构与算法、网络编程与数据库是面试中利器。想想自己工作2.5年月薪还不到10K,过着苦逼的码农生活,而他们一出校门就是大放光芒(最起码进入的公司就让人觉得牛逼哄哄的).本人痛定…

二叉树学习之非递归遍历

二叉树递归遍历可谓是学过数据结构的同仁都能想一下就能写出来,但在应聘过程我们常常遇到的是写出一个二叉树非递归遍历函数,接着上篇文章写二叉树的非递归遍历,先难后易,一步一步的来. 先上代码: #include "binarytree.h" #include <stack> #include <queu…

二叉树学习之堆排序

认识堆是从堆排序开始的 二叉堆是完全二叉树或者是近似完全二叉树,堆存储在数组中: 根结点下标为0时,下标为n的元素的子结点下标分别为2*n1,2*n2,其父结点下标为(n-1)/2 二叉堆的特性: 1、父结点的键值总是>(<)任何一个子结点的键值 2、每个结点的左右子树都是二叉堆…

步入github世界

在源码的世界里&#xff0c;越来越多的优秀源码涌现&#xff0c;开源的世界不但代表他的优秀&#xff0c;也代表了他优秀的传播途径。 https://github.com/ github自从2008年现世&#xff0c;可谓是后来者居上。开源代码的公开库&#xff0c;优秀程序员的博客园&#xff0c;热心…