C语言线程和链表

汪汪队立大功qqz

实现步骤：
1. 创建两个线程（线程A和线程B）
2. 实现链表的增删打印功能
3. 实现线程A监测用户输入。 输入data（不定长，涉及到malloc）， 以及该data保存的时间time。并插入到链表。每添加一个节点就打印所有节点
4. 实现线程B定时监测链表的数据，当time到期之后就删除该data节点。每删除一个节点就打印所有节点
有大佬教教我怎么写吗

人造人

main.c

1. #include "common.h"
   
2. #include <stdlib.h>
   
3. 
   
4. parameter_t *parameter_init(void) {
   
5.     parameter_t *parameter = malloc(sizeof(*parameter));
   
6.     parameter->exit = false;
   
7.     parameter->list = list_init();
   
8.     pthread_mutex_init(&parameter->mutex, NULL);
   
9.     return parameter;
   
10. }
    
11. 
    
12. void parameter_deinit(parameter_t *parameter) {
    
13.     pthread_mutex_destroy(&parameter->mutex);
    
14.     list_deinit(parameter->list);
    
15.     free(parameter);
    
16. }
    
17. 
    
18. int main(void) {
    
19.     parameter_t *parameter = parameter_init();
    
20.     pthread_t thread[2];
    
21.     pthread_create(&thread[0], NULL, thread_A, parameter);
    
22.     pthread_create(&thread[1], NULL, thread_B, parameter);
    
23.     void *rv;
    
24.     pthread_join(thread[0], &rv);
    
25.     pthread_join(thread[1], &rv);
    
26.     parameter_deinit(parameter);
    
27.     return 0;
    
28. }
    

复制代码

common.h

1. #ifndef _COMMON_H_
   
2. #define _COMMON_H_
   
3. 
   
4. #include "list.h"
   
5. #include <stdbool.h>
   
6. #include <pthread.h>
   
7. #include <time.h>
   
8. 
   
9. typedef struct {
   
10.     volatile bool exit;
    
11.     list_t *list;
    
12.     pthread_mutex_t mutex;
    
13. } parameter_t;
    
14. 
    
15. typedef struct {
    
16.     size_t data;
    
17.     time_t time;
    
18. } element_t;
    
19. 
    
20. void *thread_A();
    
21. void *thread_B();
    
22. void list_output(const list_t *list);
    
23. 
    
24. #endif
    

复制代码

common.c

1. #include "common.h"
   
2. #include <stdio.h>
   
3. 
   
4. void list_output(const list_t *list) {
   
5.     for(size_t i = 0; i < list_size(list); ++i) {
   
6.         element_t e;
   
7.         list_get(list, i, &e, sizeof(e));
   
8.         printf("%lu ", e.data);
   
9.     }
   
10.     puts("");
    
11. }
    

复制代码

list.h

1. #ifndef _LIST_H_
   
2. #define _LIST_H_
   
3. 
   
4. #include <stddef.h>
   
5. #include <stdbool.h>
   
6. 
   
7. struct list_node_tag {
   
8.     void *data; size_t size;
   
9.     struct list_node_tag *next;
   
10. };
    
11. 
    
12. typedef struct {
    
13.     struct list_node_tag *head;
    
14.     size_t size;
    
15. } list_t;
    
16. 
    
17. list_t *list_init(void);
    
18. void list_deinit(list_t *list);
    
19. bool list_clean(list_t *list);
    
20. bool list_insert(list_t *list, size_t index, const void *data, size_t size);
    
21. bool list_delete(list_t *list, size_t index);
    
22. bool list_get(const list_t *list, size_t index, void *data, size_t size);
    
23. bool list_set(list_t *list, size_t index, const void *data, size_t size);
    
24. bool list_append(list_t *list, const void *data, size_t size);
    
25. size_t list_size(const list_t *list);
    
26. bool list_empty(const list_t *list);
    
27. 
    
28. #endif
    

复制代码

list.c

1. #include "list.h"
   
2. #include <stdlib.h>
   
3. #include <memory.h>
   
4. 
   
5. list_t *list_init(void) {
   
6.     list_t *list = malloc(sizeof(*list));
   
7.     if(!list) return NULL;
   
8.     list->head = NULL;
   
9.     list->size = 0;
   
10.     return list;
    
11. }
    
12. 
    
13. void list_deinit(list_t *list) {
    
14.     if(!list) return;
    
15.     list_clean(list);
    
16.     free(list);
    
17. }
    
18. 
    
19. bool list_clean(list_t *list) {
    
20.     if(!list) return false;
    
21.     while(!list_empty(list)) list_delete(list, 0);
    
22.     return true;
    
23. }
    
24. 
    
25. bool list_insert(list_t *list, size_t index, const void *data, size_t size) {
    
26.     if(!list) return false;
    
27.     if(list_size(list) < index) return false;
    
28.     if(!data) return false;
    
29.     struct list_node_tag **current = &list->head;
    
30.     while(index--) current = &(*current)->next;
    
31.     struct list_node_tag *node = malloc(sizeof(*node));
    
32.     if(!node) return false;
    
33.     node->data = malloc(size);
    
34.     if(!node->data) {free(node); return false;}
    
35.     memcpy(node->data, data, size);
    
36.     node->size = size;
    
37.     node->next = *current;
    
38.     *current = node;
    
39.     ++list->size;
    
40.     return true;
    
41. }
    
42. 
    
43. bool list_delete(list_t *list, size_t index) {
    
44.     if(!list) return false;
    
45.     if(list_size(list) <= index) return false;
    
46.     struct list_node_tag **current = &list->head;
    
47.     while(index--) current = &(*current)->next;
    
48.     struct list_node_tag *temp = *current;
    
49.     *current = temp->next;
    
50.     free(temp->data); free(temp);
    
51.     --list->size;
    
52.     return true;
    
53. }
    
54. 
    
55. bool list_get(const list_t *list, size_t index, void *data, size_t size) {
    
56.     if(!list) return false;
    
57.     if(list_size(list) <= index) return false;
    
58.     if(!data) return false;
    
59.     struct list_node_tag *const *current = &list->head;
    
60.     while(index--) current = &(*current)->next;
    
61.     struct list_node_tag *temp = *current;
    
62.     if(temp->size > size) return false;
    
63.     memcpy(data, temp->data, temp->size);
    
64.     return true;
    
65. }
    
66. 
    
67. bool list_set(list_t *list, size_t index, const void *data, size_t size) {
    
68.     bool res = list_delete(list, index);
    
69.     return res ? list_insert(list, index, data, size) : res;
    
70. }
    
71. 
    
72. bool list_append(list_t *list, const void *data, size_t size) {
    
73.     if(!list) return false;
    
74.     return list_insert(list, list_size(list), data, size);
    
75. }
    
76. 
    
77. size_t list_size(const list_t *list) {
    
78.     if(!list) return 0;
    
79.     return list->size;
    
80. }
    
81. 
    
82. bool list_empty(const list_t *list) {
    
83.     if(!list) return true;
    
84.     return list_size(list) == 0;
    
85. }
    

复制代码

thread_A.c

1. #include "common.h"
   
2. #include <stdio.h>
   
3. 
   
4. void *thread_A(parameter_t *parameter) {
   
5.     while(1) {
   
6.         element_t e;
   
7.         if(scanf("%lu%lu", &e.data, &e.time) != 2) break;
   
8.         if(!e.time) break;
   
9.         pthread_mutex_lock(&parameter->mutex);
   
10.         list_append(parameter->list, &e, sizeof(e));
    
11.         list_output(parameter->list);
    
12.         pthread_mutex_unlock(&parameter->mutex);
    
13.     }
    
14.     parameter->exit = true;
    
15.     return NULL;
    
16. }
    

复制代码

thread_B.c

1. #include "common.h"
   
2. #include <unistd.h>
   
3. 
   
4. static void list_data_next(list_t *list) {
   
5.     for(size_t i = 0; i < list_size(list); ++i) {
   
6.         element_t e;
   
7.         list_get(list, i, &e, sizeof(e));
   
8.         if(!--e.time) {
   
9.             list_delete(list, i);
   
10.             list_output(list);
    
11.             continue;
    
12.         }
    
13.         list_set(list, i, &e, sizeof(e));
    
14.     }
    
15. }
    
16. 
    
17. void *thread_B(parameter_t *parameter) {
    
18.     static size_t count;
    
19.     while(1) {
    
20.         usleep(100000);
    
21.         if(parameter->exit) break;
    
22.         if(++count == 10) {
    
23.             count = 0;
    
24.             pthread_mutex_lock(&parameter->mutex);
    
25.             list_data_next(parameter->list);
    
26.             pthread_mutex_unlock(&parameter->mutex);
    
27.         }
    
28.     }
    
29.     return NULL;
    
30. }
    

复制代码

1. gcc -g -Wall -o main main.c list.c thread_A.c thread_B.c common.c -lpthread

复制代码

jhq999

人造人 发表于 2021-12-29 20:23
main.c

jhq999

人造人 发表于 2021-12-29 20:23
main.c

pthread_create是不是不能直接用于window,window是不是得用CreateThread

人造人

jhq999 发表于 2021-12-30 16:39
pthread_create是不是不能直接用于window,window是不是得用CreateThread

windows下可以装一个cygwin来用这个代码
我记得好像dev-cpp也能用这个代码

jhq999

人造人 发表于 2021-12-30 17:15
windows下可以装一个cygwin来用这个代码
我记得好像dev-cpp也能用这个代码

谢谢