#include
#include
#include
#include
#include
#include
#define THREAD_NUM 25
typedef struct
{undefined
FILE *_fp
int _nThreadId//第几个线程
sem_t *_semLock
}IDD_THREAD_PARAM
void *ThreadFunc(void *args)
{undefined
char sLine[100+1]
FILE *fpRead = ((IDD_THREAD_PARAM *)args)->_fp
sem_t *semLock = ((IDD_THREAD_PARAM *)args)->_semLock
int nId = ((IDD_THREAD_PARAM *)args)->_nThreadId
sem_wait(semLock)
while(!feof(fpRead))
{undefined
memset(sLine,0,sizeof(sLine))
fgets(sLine,100,fpRead)
fprintf(stderr,"Thread ID-%d:%s",nId,sLine)
}
sem_post(semLock)
}
int main()
{undefined
pthread_t *pThreads
sem_t semLock
pThreads = (pthread_t *)malloc(THREAD_NUM*sizeof(pthread_t))
sem_init(&semLock,0,1)
FILE *fp = fopen("test.txt","r")
//开始线程循环
IDD_THREAD_PARAM param
for(int i=0i
{undefined
memset(param,0,sizeof(IDD_THREAD_PARAM))
param._fp = fp
param._nThreadId = i
param._semLock = &semLock
pthread_create((pThreads+i),NULL,ThreadFunc,param)
}
for(int i=0i
pthread_join(*(pThreads+i),NULL)
free(pThreads)
pThreads = NULL
fclose(fp)
fp = NULL
return 0
}
下，应该差不多一、如何建立线程
用到的头文件
(a)pthread.h
(b)semaphore.h
(c) stdio.h
(d)string.h
定义线程标识
pthread_t
创建线程
pthread_create
对应了一个函数作为线程的程序段
注意的问题
要保证进程不结束（在创建线程后加死循环）
在线程中加入While(1)语句，也就是死循环，保证进程不结束。
二、控制线程并发的函数
sem_t：信号量的类型
sem_init：初始化信号量
sem_wait：相当于P操作
sem_post：相当于V操作
三、实现原形系统
父亲、母亲、儿子和女儿的题目：
桌上有一只盘子，每次只能放入一只水果。爸爸专放苹果，妈妈专放橘子，一个儿子专等吃盘子中的橘子，一个女儿专等吃盘子中的苹果。分别用P，V操作和管程实现
每个对应一个线程
pthread_t father father进程
pthread_t mother mother进程
pthread_t son son进程
pthread_t daughter daughter进程
盘子可以用一个变量表示
sem_t empty
各线程不是只做一次，可以是无限或有限次循环
用While(1)控制各线程无限次循环
输出每次是那个线程执行的信息
printf("%s\n",(char *)arg)通过参数arg输出对应线程执行信息
编译方法
gcc hex.c -lpthread
生成默认的可执行文件a.out
输入./a.out命令运行
查看结果：程序连续运行显示出
father input an apple.
daughter get an apple.
mother input an orange.
son get an orange.
mother input an orange.
son get an orange.
………………..
四、程序源代码
#include <stdio.h>
#include<string.h>
#include <semaphore.h>
#include <pthread.h>
sem_t empty //定义信号量
sem_t applefull
sem_t orangefull
void *procf(void *arg) //father线程
{
while(1){
sem_wait(&empty)//P操作
printf("%s\n",(char *)arg)
sem_post(&applefull)//V操作
sleep(7)
}
}
void *procm(void *arg) //mother线程
{
while(1){
sem_wait(&empty)
printf("%s\n",(char *)arg)
sem_post(&orangefull)
sleep(3)
}
}
void *procs(void *arg) //son线程
{
while(1){
sem_wait(&orangefull)
printf("%s\n",(char *)arg)
sem_post(&empty)
sleep(2)
}
}
void *procd(void *arg) //daughter线程
{
while(1){
sem_wait(&applefull)
printf("%s\n",(char *)arg)
sem_post(&empty)
sleep(5)
}
}
main()
{
pthread_t father //定义线程
pthread_t mother
pthread_t son
pthread_t daughter
sem_init(&empty, 0, 1) //信号量初始化
sem_init(&applefull, 0, 0)
sem_init(&orangefull, 0, 0)
pthread_create(&father,NULL,procf,"father input an apple.") //创建线程
pthread_create(&mother,NULL,procm,"mother input an orange.")
pthread_create(&daughter,NULL,procd,"daughter get an apple.")
pthread_create(&son,NULL,procs,"son get an orange.")
while(1){} //循环等待
}
另外,站长团上有产品团购,便宜有保证
第一章：绪论？内核版本号格式：x.y.zz-www／x为主版本号，y为次版本号，zz为次次版本号，www为发行号／次版本号改变说明内核有重大变革，其偶数为稳定版本，奇数为尚在开发中的版本
第二章：基础？
文件种类：-：txt，二进制／d：目录／l：链接文件（link）／b：区块设备文件／c：字符设备文件／p：管道
目录结构：bin：可执行／boot：开机引导／dev：设备文件／etc：系统配置文件／lib：库文件／mnt：设备挂载点／var：系统日志／
命令：rmdir：删除空目录／find [path] [expression]／touch命令还可以修改指定文件的最近一次访问时间／tar -czvf usr.tar.gz path／tar –zxvf usr.tar.gz／tar –cjvf usr.tar.bz2 path／tar –jxvf usr.tar.bz2
gcc：预处理：-g／I在头文件搜索路径中添加目录，L在库文件搜索路径中
gdb：设置断点：b／查看断点信息：info
Makefile：make –f other_makefile／<：第一个依赖文件的名称／@：目标文件的完整名称／^：所有不重复的依赖文件／+：所有依赖文件（可能重复）
第三章：文件IO
read：read(fd, temp, size)／读fd中长度为size的值到temp／返回0表示file为NULL
write：write(fd, buf, buf_size)／写长度为buf_size的buf内容到fd中
lseek：lseek(fd, offset, SEEK_SET)／从文件开头向后增加offset个位移量
unlink：从文件系统中删除一个名字
open1：int open(const char * pathname, int flags, mode_t mode)／flags为读写方式／mode为权限设置／O_EXCL：测试文件是否存在／O_TRUNC：若存在同名文件则删除之并新建
open2：注意O_NONBLOCK
mmap.1：void *mmap(void *start, size_t length, int prot, int flags, int fd, off_t offsize)
mmap.2：mmap(start_addr, flength, PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0)
fcntl：上锁／int fcntl(int fd, int cmd, struct flock * lock)／对谁；做什么；设置所做内容
select：fd_max+1，回传读状况，回传写状况，回传异常，select等待的时间／NULL为永远等待／0为从不等待／凡需某状况则用之，反则(fd_set *)NULL之
FD_*那几个函数……
一般出错则返回-1
第四章：文件与目录
硬链接与符号链接？
chdir改变目录
0：in／1：out／2：err
第五章：内存管理
可执行文件存储时：代码区、数据区和未初始化区
栈：by编译器，向低址扩展，连续，效率高／堆：by程序员
/etc/syslog.conf，系统log记录文件／优先级为-20时最高
第六章：进程和信号
程序代码、数据、变量、文件描述符和环境／init的pid为1
execl族：int execl(const char * path, const char * arg, ....)／path即可执行文件的路径，一般为.／最后一个参数以NULL结束
waitpid：waitpid(pid_t pid,int * status,int options)／option：一般用WNOHANG，没有已经结束的子进程则马上返回，不等待
kill：int kill(pid_t pid,int sig)／发送信号sig给pid
void (*signal(int signum, void(* handler)(int)))(int)／第一个参数被满足时，执行handler／第一个参数常用：SIG_IGN：忽略信号／SIG_DFL：恢复默认信号
第七章：线程
sem_init(sem_t *sem, int pshared, unsigned int value)／pshared为0／value即初始值
第八章：管道
1：write／0：read
第九章：信号量、共享内存和消息队列
临界资源：操作系统中只允许一个进程访问的资源／临界区：访问临界资源的那段代码
信号量：建立联系（semget），然后初始化，PV操作，最后destroy
共享内存没有提供同步机制
第十章：套接字
UDP：无连接协议，无主客端的区分／实时性
TCP：字节流／数据可靠性／网络可靠性
数据报：SOCK_STREAM／SOCK_DGRAM
其它
管道一章的both_pipe即父子进程间的全双工管道通讯
关系到信号和互斥的服务器-客户端程序
线程一章的class的multi_thread文件夹下的thread8.c
int main(void)
{
int data_processed
int file_pipes_1[2]
int file_pipes_2[2]
char buffer[BUFSIZ + 1]
const char some_data[] = "123"
const char ch2p[] = "this is the string from child to the parent!"
const char p2ch[] = "this is the string from parent to the child!"
pid_t fork_result
memset(buffer,'\0',sizeof(buffer))
if(pipe(file_pipes_1) == 0){
if(pipe(file_pipes_2) == 0){
fork_result = fork()
switch(fork_result){
case -1:
perror("fork error")
exit(EXIT_FAILURE)
case 0://child
close(file_pipes_1[1])
close(file_pipes_2[0])
printf("in the child!\n")
read(file_pipes_1[0],buffer, BUFSIZ)
printf("in the child, read_result is \"%s\"\n",buffer)
write(file_pipes_2[1],ch2p, sizeof(ch2p))
printf("in the child, write_result is \"%s\"\n",ch2p)
exit(EXIT_SUCCESS)
default://parent
close(file_pipes_1[0])
close(file_pipes_2[1])
printf("in the parent!\n")
write(file_pipes_1[1], p2ch, sizeof(p2ch))
printf("in the parent, write_result is \"%s\"\n",p2ch)
read(file_pipes_2[0],buffer, BUFSIZ)
printf("in the parent, read_result is \"%s\"\n",buffer)
exit(EXIT_SUCCESS)
}
}
}
}
#ifndef DBG
#define DBG
#endif
#undef DBG
#ifdef DBG
#define PRINTF(fmt, args...) printf("file->%s line->%d: " \
fmt, __FILE__, __LINE__, ##args)
#else
#define PRINTF(fmt, args...) do{}while(0)
#endif
int main(void)
{
PRINTF("%s\n", "hello!")
fprintf(stdout, "hello hust!\n")
return 0
}
#define N 5
#define MAX 5
int nput = 0
char buf[MAX][50]
char *buffer = "abcdefghijklmnopqrstuvwxyz0123456789"
char buf_r[100]
sem_t mutex,full,avail
void *productor(void *arg)
void *consumer(void *arg)
int i = 0
int main(int argc, char **argv)
{
int cnt = -1
int ret
int nput = 0
pthread_t id_produce[10]
pthread_t id_consume
ret = sem_init(&mutex, 0, 1)
ret = sem_init(&avail, 0, N)
ret = sem_init(&full, 0, 0)
for(cnt = 0cnt <6cnt ++ ){
//pthread_create(&id_produce[cnt], NULL, (void *)productor, &cnt)
pthread_create(&id_produce[cnt], NULL, (void *)productor, (void *)cnt)
}
pthread_create(&id_consume, NULL, (void *)consumer, NULL)
for(cnt = 0cnt <6cnt ++){
pthread_join(id_produce[cnt], NULL)
}
pthread_join(id_consume,NULL)
sem_destroy(&mutex)
sem_destroy(&avail)
sem_destroy(&full)
exit(EXIT_SUCCESS)
}
void *productor(void *arg)
{
while(1){
sem_wait(&avail)
sem_wait(&mutex)
if(nput >= MAX * 3){
sem_post(&avail)
//sem_post(&full)
sem_post(&mutex)
return NULL
}
sscanf(buffer + nput, "%s", buf[nput % MAX])
//printf("write[%d] \"%s\" to the buffer[%d]\n", (*(int*)arg), buf[nput % MAX],nput % MAX)
printf("write[%d] \"%s\" to the buffer[%d]\n", (int)arg, buf[nput % MAX],nput % MAX)
nput ++
printf("nput = %d\n", nput)
sem_post(&mutex)
sem_post(&full)
}
return NULL
}
void *consumer(void *arg)
{
int nolock = 0
int ret, nread, i
for(i = 0 i <MAX * 3i++)
{
sem_wait(&full)
sem_wait(&mutex)
memset(buf_r, 0, sizeof(buf_r))
strncpy(buf_r, buf[i % MAX], sizeof(buf[i % MAX]))
printf("read \"%s\" from the buffer[%d]\n\n",buf_r, i % MAX)
sem_post(&mutex)
sem_post(&avail)
//sleep(1)
}
return NULL
}
欢迎分享，转载请注明来源：夏雨云
微信扫一扫
支付宝扫一扫
评论列表（0条）