龙岗网站,一键搭建网站系统,推广平台软件,网络销售网站有哪些1 使用无名管道完成父子进程间的通信
#includemyhead.hint main(int argc, const char *argv[])
{//创建存放两个文件描述符的数组int fd[2];int pid -1;//打开无名管道if(pipe(fd) -1){perror(pipe);return -1;}//创建子进程pid fork();if(pid 使用无名管道完成父子进程间的通信
#includemyhead.hint main(int argc, const char *argv[])
{//创建存放两个文件描述符的数组int fd[2];int pid -1;//打开无名管道if(pipe(fd) -1){perror(pipe);return -1;}//创建子进程pid fork();if(pid 0){//父进程//关闭读端close(fd[0]);char buf[128];while(1){printf(请输入);fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1] 0;write(fd[1],buf,strlen(buf));if(strcmp(buf,quit) 0){break;}}close(fd[1]);}else if(pid 0){//子进程close(fd[1]);char buf[128];while(1){bzero(buf,sizeof(buf));read(fd[0],buf,sizeof(buf));printf(输出是%s\n,buf);if(strcmp(buf,quit) 0){break;}}close(fd[0]);}else{perror(fork);return -1;}wait(NULL);return 0;
}效果图: 2 使用标准IO完成两个文件的拷贝
#includemyhead.hint main(int argc, const char *argv[])
{FILE* rfile;FILE* wfile;if((rfile fopen(./01test.c,r)) NULL){perror(fopen);return -1;}if((wfile fopen(./02test.txt,w)) NULL){perror(fopen);return -1;}char buf[128];int res 0;while(1){res fread(buf,1,sizeof(buf),rfile);if(res 0 || res -1){break;}fwrite(buf,res,1,wfile);}fclose(rfile);fclose(wfile);return 0;
}效果图: 3 使用文件IO实现两个文件的拷贝
#includemyhead.hint main(int argc, const char *argv[])
{pid_t rpid -1;pid_t wpid -1;if((rpid open(./01test.c,O_RDONLY))-1){perror(open);return -1;}if((wpid open(./03test.txt,O_WRONLY | O_CREAT | O_TRUNC,0664))-1){perror(open);return -1;}char buf[128];int res 0;while(1){bzero(buf,sizeof(buf));res read(rpid,buf,sizeof(buf));if(res 0||res -1){break;}write(wpid,buf,res);}close(rpid);close(wpid);return 0;
}效果图: 4 使用多进程完成两个文件的拷贝
#includemyhead.hint main(int argc, const char *argv[])
{pid_t pid -1;int rfd -1;int wfd -1;if((rfd open(./01test.c,O_RDONLY))-1){perror(open);return -1;}if((wfd open(./04test.txt,O_WRONLY|O_CREAT|O_TRUNC,0664))-1){perror(open);return -1;}int len lseek(rfd,0,SEEK_END);pid fork();if(pid 0){ lseek(rfd,0,SEEK_SET);lseek(wfd,0,SEEK_SET);char buf[128];int res -1;int num 0;while(1){ res read(rfd,buf,sizeof(buf));num res;if(num len/2||res 0){write(wfd,buf,res-(num-len/2));break;}write(wfd,buf,res);}close(rfd);close(wfd);wait(NULL);}else if(pid 0){lseek(rfd,len/2,SEEK_SET);lseek(wfd,len/2,SEEK_SET);char buf[128];int res -1;int num 0;while(1){ res read(rfd,buf,sizeof(buf));num res;if(num (len-len/2) || res 0){write(wfd,buf,res-(num-len/2));break;}write(wfd,buf,res);}close(rfd);close(wfd);exit(EXIT_SUCCESS);}else{perror(fork);return -1;}return 0;
}效果图: 5 使用多线程完成两个文件的拷贝
#includemyhead.h
typedef struct
{const char* srcfile;const char* destfile;int place;int offset;
}arg;void* read_file(void* aarg)
{arg ofile*((arg*)aarg);printf( %s %s %d %d\n,ofile.srcfile,ofile.destfile,ofile.place,ofile.offset);int rfd -1;int wfd -1;if((rfd open(ofile.srcfile,O_RDONLY))-1){perror(open);pthread_exit(NULL);}if((wfd open(ofile.destfile,O_WRONLY|O_CREAT,0664))-1){perror(open);pthread_exit(NULL);}lseek(rfd,ofile.place,SEEK_SET);lseek(wfd,ofile.place,SEEK_SET);char buf[128];int res 0;int num 0;while(1){bzero(buf,sizeof(buf));res read(rfd,buf,sizeof(buf));num res;if(num ofile.offset||res 0){write(wfd,buf,res-(num-ofile.offset));break;}write(wfd,buf,res);} close(rfd);close(wfd);pthread_exit(NULL);}int main(int argc, const char *argv[])
{pthread_t rtid -1;pthread_t wtid -1;pid_t fd -1;if((fd open(argv[1],O_RDONLY))-1){perror(open);return -1;}int len lseek(fd,0,SEEK_END);close(fd);arg ofile_information{argv[1],argv[2],0,len/2};if((pthread_create(rtid,NULL,read_file,ofile_information)) ! 0){perror(pthread_creat);return -1;}arg tfile_information{argv[1],argv[2],len/2,len-(len/2)};if((pthread_create(wtid,NULL,read_file,tfile_information)) ! 0){perror(pthread_creat);return -1;}pthread_join(rtid,NULL);pthread_join(wtid,NULL);return 0;
}效果图: 6 将互斥锁的案例重新写一遍
#includemyhead.hpthread_mutex_t mutex;
int money 5000;void* cost(void* arg)
{while(1){pthread_mutex_lock(mutex);money - 50; printf(小王花了50,还剩%d\n,money);pthread_mutex_unlock(mutex);sleep(1);}pthread_exit(NULL);
}int main(int argc, const char *argv[])
{pthread_t tid;//初始化pthread_mutex_init(mutex,NULL);if(pthread_create(tid,NULL,cost,NULL) ! 0){perror(pthread_create);return -1;}//上锁while(1){sleep(1);pthread_mutex_lock(mutex);money - 100;printf(小张花了100还剩:%d\n,money);pthread_mutex_unlock(mutex);}pthread_mutex_destroy(mutex);pthread_join(tid,NULL);return 0;
}效果图: 7 将无名信号量实现生产者消费者程序重新实现一遍
#includemyhead.hsem_t sem;void* task1(void* arg)
{while(1){printf(我生产了\n);sem_post(sem);sleep(1);}pthread_exit(NULL);
}void* task2(void* arg)
{while(1){sem_wait(sem);printf(我消费了\n);//sem_post(sem);sleep(1);}pthread_exit(NULL);
}int main(int argc, const char *argv[])
{pthread_t tid1;pthread_t tid2;//初始化sem_init(sem,0,0);if(pthread_create(tid1,NULL,task1,NULL) ! 0){perror(pthread_create);return -1;}if(pthread_create(tid2,NULL,task2,NULL) ! 0){perror(pthread_create);return -1;}sem_destroy(sem);pthread_join(tid1,NULL);pthread_join(tid2,NULL);return 0;
}效果图: 8 将条件变量实现生产者消费者程序重新实现一遍
#includemyhead.hpthread_cond_t cond;
pthread_mutex_t mutex;void* task1(void* arg)
{while(1){printf(生产了一个\n);pthread_cond_signal(cond);sleep(1);}
}void* task2(void* arg)
{while(1){pthread_mutex_lock(mutex);pthread_cond_wait(cond,mutex);printf(%#lx消费了一个\n,pthread_self());pthread_mutex_unlock(mutex);sleep(1);}
}int main(int argc, const char *argv[])
{pthread_t tid1,tid2,tid3,tid4,tid5,tid6;//初始化pthread_cond_init(cond,NULL);pthread_mutex_init(mutex,NULL);//生产线if(pthread_create(tid1,NULL,task1,NULL) ! 0){perror(pthread_create);return -1;}//消费线if(pthread_create(tid2,NULL,task2,NULL) ! 0){perror(pthread_create);return -1;}if(pthread_create(tid3,NULL,task2,NULL) ! 0){perror(pthread_create);return -1;}if(pthread_create(tid4,NULL,task2,NULL) ! 0){perror(pthread_create);return -1;}if(pthread_create(tid5,NULL,task2,NULL) ! 0){perror(pthread_create);return -1;}if(pthread_create(tid6,NULL,task2,NULL) ! 0){perror(pthread_create);return -1;}pthread_join(tid1,NULL);pthread_join(tid2,NULL);pthread_join(tid3,NULL);pthread_join(tid4,NULL);pthread_join(tid5,NULL);pthread_join(tid6,NULL);pthread_cond_destroy(cond);pthread_mutex_destroy(mutex);return 0;
}效果图:
