Question

linux实现消费者生产者进程同步，就是生产者生产一个，消费者消费一个。在已有代码上修改。

生产者代码(producer.c)：
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <stdio.h>
#include <errno.h>
#define EXIT_FAILURE -1
#define EXIT_SUCCESS -1
#define SHMSZ 100
#define PATH "/tmp"
int main(void)
{
key_t key;
intshmid;
void *shm;
char *s,c;
key=ftok(PATH,'a');
if((shmid=shmget(key,SHMSZ,IPC_CREAT|0666))<0)
{
perror("shmget error");
exit(EXIT_FAILURE);
}
if((shm=shmat(shmid,NULL,0))==(char *)-1)
{
perror("shmat error");
printf("errno:%d\n",errno);
exit(EXIT_FAILURE);
}
s=shm;
for(c='a';c<='z';c++)
*s++=c;
*s=NULL;
while(*(char*)shm!='*') sleep(1);
shmdt(shm);
exit(EXIT_SUCCESS);
}

消费者代码(consumer.c)：
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#define EXIT_FAILURE -1
#define EXIT_SUCCESS 0
#define SHMSZ 100
#define PATH "/tmp"
int main(void)
{
intshmid;
void *shm;
char *s;
key_t key;
key=ftok(PATH,'a');
if((shmid=shmget(key,SHMSZ,0666))<0)
{
perror("shmget error");
exit(EXIT_FAILURE);
}
if((shm=shmat(shmid,NULL,0))==(char *)-1)
{
perror("shmat error");
exit(EXIT_FAILURE);
}
for(s=(char*)shm;*s!=NULL;s++)
putchar(*s);
putchar('\n');
*(char*)shm='*';
shmdt(shm);
exit(EXIT_SUCCESS);
}

Answer 1

1.                
   

3. 1

4. 自己稍微改改

7. 1

8. 2

9. 3

10. 4

11. 5

12. 6

13. 7

14. 8

15. 9

16. 10

17. 11

18. 12

19. 13

20. 14

21. 15

22. 16

23. 17

24. 18

25. 19

26. 20

27. 21

28. 22

29. 23

30. 24

31. 25

32. 26

33. 27

34. 28

35. 29

36. 30

37. 31

38. 32

39. 33

40. 34

41. 35

42. 36

43. 37

44. 38

45. 39

46. 40

47. 41

48. 42

49. 43

50. 44

51. 45

52. 46

53. 47

54. 48

55. 49

56. 50

57. 51

58. 52

59. 53

60. 54

61. 55

62. #include <stdio.h>

63. #include <pthread.h>

64. char data[5];//仓库，用于存放char

65. int size = 0;//库存数

66. pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

67. pthread_cond_t full = PTHREAD_COND_INITIALIZER;

68. pthread_cond_t empty = PTHREAD_COND_INITIALIZER;

69. void print(){

70.   int i;

71.   for(i=0;i<size;i++){

72.     printf("%c ",data[i]);

73.   }

74.   printf("\n");

75. }

76. //生产者线程

77. void* product(void *p){

78.   char c;

79.   for(c='A';c<='Z';c++){

80.     pthread_mutex_lock(&mutex);//mutex内部才能使用cond

81.     while(size==5) //阻塞生产同时释放互斥 (旋锁)

82.       pthread_cond_wait(&full,&mutex);//阻塞生产线程

83.     printf("PUSH %c\n",c);

84.     data[size] = c;

85.     usleep(10000);

86.     size++;

87.     print();

88.     pthread_cond_broadcast(&empty);//释放消费cond

89.     pthread_mutex_unlock(&mutex);

90.     usleep(200000);

91.   }

92. }

93. //消费者线程

94. void* custom(void *p){

95.   int i;

96.   for(i=0;i<52;i++){

97.     pthread_mutex_lock(&mutex);

98.     while(size==0)

99.       pthread_cond_wait(&empty,&mutex);

100.     printf("POP %c\n",data[size-1]);

101.     size--;

102.     print();

103.     pthread_cond_broadcast(&full);

104.     pthread_mutex_unlock(&mutex);

105.     usleep(400000);

106.   }

107. }

108. int main(){

109.   pthread_t id1,id2,id3;

110.   pthread_create(&id1,0,product,0);

111.   pthread_create(&id3,0,product,0);

112.   pthread_create(&id2,0,custom,0);

113.   pthread_join(id1,0); pthread_join(id2,0);

114.   pthread_join(id3,0);

115.   pthread_mutex_destroy(&mutex);

116. }

追问

亲，对我的代码修改，你这代码不符合我的要求，我要是会改我就改我自己的啦？