zoukankan html css js c++ java

啊啊啊啊

实验一：

邻接表：

 1 #include <iostream>
 2 using namespace std;
 3 const int MAX = 30;
 4 typedef int SubType;
 5 typedef bool WeightType;
 6 struct Node//结点
 7 {
 8     SubType sub;
 9     WeightType weight;
10     struct Node* pNext = NULL;
11 };
12 typedef struct Vertex//表顶点
13 {
14     struct Node* pHead;
15 }AdjList[MAX];
16 void Insert_(AdjList adj, SubType v1, SubType v2, WeightType w)
17 {
18     struct Node* s = new struct Node;
19     s->pNext = NULL;
20     s->sub = v2;
21     s->weight = w;
22     if (adj[v1].pHead == NULL)
23     {
24         adj[v1].pHead = s;
25     }
26     else
27     {
28         struct Node* p = adj[v1].pHead;
29         struct Node* pr = NULL;
30         while (p != NULL)
31         {
32             if (p->sub == v2)//已存在，无需插入，修改权值
33             {
34                 p->weight = w;
35                 return;
36             }
37             pr = p;
38             p = p->pNext;
39         }
40         pr->pNext = s;
41     }
42 }
43 void Insert(AdjList adj, SubType v1, SubType v2, WeightType w)
44 {
45     Insert_(adj, v1, v2, w);
46     Insert_(adj, v2, v1, w);
47 }
48 int main()
49 {
50     AdjList G;
51     for (int i = 0; i < MAX; ++i)
52         G[i].pHead = NULL;
53 
54     Insert(G, 0, 2, true);
55 
56     return 0;
57 }

View Code

邻接矩阵：

 1 #include <iostream>
 2 using namespace std;
 3 const int MAX = 30;
 4 typedef int SubType;
 5 typedef bool WeightType;
 6 void Insert(WeightType (*G)[MAX], SubType v1, SubType v2, WeightType w)
 7 {
 8     G[v1][v2] = G[v2][v1] = w;
 9 }
10 int main()
11 {
12     WeightType G[MAX][MAX];
13     for(int i=0;i<MAX;++i)
14         for (int j = 0; j < MAX; ++j)
15         {
16             G[i][j] = i == j ? true : false;
17         }
18     Insert(G, 0, 5, true);
19     return 0;
20 }

View Code

实验二：

BFS+DFS（邻接表）：

  1 #include <iostream>
  2 using namespace std;
  3 const int MAX = 30;
  4 int first = 0;
  5 typedef int SubType;
  6 typedef bool WeightType;
  7 bool visited[MAX][MAX];
  8 bool inQueue[MAX];
  9 typedef struct Node//结点
 10 {
 11     SubType sub;
 12     WeightType weight;
 13     struct Node* pNext = NULL;
 14 };
 15 struct Queue
 16 {
 17     SubType s[MAX];
 18     int r = -1;
 19     int f = -1;
 20 };
 21 Queue q;
 22 typedef struct Vertex//表顶点
 23 {
 24     struct Node* pHead;
 25 }AdjList[MAX];
 26 void Insert_(AdjList adj, SubType v1, SubType v2, WeightType w)
 27 {
 28     struct Node* s = new struct Node;
 29     s->pNext = NULL;
 30     s->sub = v2;
 31     s->weight = w;
 32     if (adj[v1].pHead == NULL)
 33     {
 34         adj[v1].pHead = s;
 35     }
 36     else
 37     {
 38         struct Node* p = adj[v1].pHead;
 39         struct Node* pr = NULL;
 40         while (p != NULL)
 41         {
 42             if (p->sub == v2)//已存在，无需插入，修改权值
 43             {
 44                 p->weight = w;
 45                 return;
 46             }
 47             pr = p;
 48             p = p->pNext;
 49         }
 50         pr->pNext = s;
 51     }
 52 }
 53 void Insert(AdjList adj, SubType v1, SubType v2, WeightType w)
 54 {
 55     Insert_(adj, v1, v2, w);
 56     Insert_(adj, v2, v1, w);
 57 }
 58 void dfs(AdjList G, SubType i)
 59 {
 60     struct Node* p = G[i].pHead;
 61     while (p != NULL)
 62     {
 63         if (!visited[i][p->sub] && p->weight == true)
 64         {
 65             visited[i][p->sub] = visited[p->sub][i] = true;
 66             if (first != 0)  cout << "->";
 67             ++first;
 68             cout << "(" << i << "," << p->sub << ")";
 69             dfs(G, p->sub);
 70         }
 71         p = p->pNext;
 72     }
 73 }
 74 void bfs(AdjList G, SubType i)
 75 {
 76     q.s[++q.f] = i;
 77     inQueue[i] = true;
 78     int cnt = 0;
 79     while (q.r < q.f)
 80     {
 81         SubType n = q.s[++q.r];
 82         if (cnt != 0)cout << "->";
 83             ++cnt;
 84         cout << n;
 85         struct Node* p = G[n].pHead;
 86         while (p != NULL)
 87         {
 88             if (!inQueue[p->sub])
 89             {
 90                 inQueue[p->sub] = true;
 91                 q.s[++q.f] = p->sub;
 92             }
 93             p = p->pNext;
 94         }
 95     }
 96 }
 97 int main()
 98 {
 99     AdjList G;
100     for (int i = 0; i < MAX; ++i)
101         G[i].pHead = NULL;
102     for (int i = 0; i < MAX; ++i)
103         for (int j = 0; j < MAX; ++j)
104         {
105             visited[i][j] = visited[j][i] = false;
106         }
107     Insert(G, 0, 2, true);
108     Insert(G, 5, 2, true);
109     Insert(G, 6, 3, true);
110     Insert(G, 7, 2, true);
111     Insert(G, 9, 3, true);
112     Insert(G, 2, 3, true);
113     cout << "DFS:";
114     dfs(G, 0);
115     cout << endl;
116     cout << "BFS:";
117     bfs(G, 0);
118     return 0;
119 }

View Code

实验三：

最小生成树（邻接表）：

Prim和Kruskal：

  1 #include <iostream>
  2 using namespace std;
  3 typedef int NumType;
  4 typedef int WeightType;
  5 const WeightType INFINITE = 65535;
  6 const NumType MAX = 6;
  7 #define MAXEDGE MAX * MAX
  8 bool InsertFlag = true;
  9 int EdgeCnt = 0;
 10 struct Node//结点
 11 {
 12     NumType sub;
 13     WeightType weight;
 14     struct Node* pNext = NULL;
 15 };
 16 typedef struct Vertex//表顶点
 17 {
 18     struct Node* pHead;
 19 }AdjList[MAX];
 20 struct Edge
 21 {
 22     NumType u, v;
 23     WeightType w;
 24 };
 25 struct Edge* edge = new struct Edge[MAXEDGE];
 26 int r = -1;
 27 void Insert_(AdjList adj, NumType v1, NumType v2, WeightType w)
 28 {
 29     struct Node* s = new struct Node;
 30     s->pNext = NULL;
 31     s->sub = v2;
 32     s->weight = w;
 33     if (adj[v1].pHead == NULL)
 34     {
 35         adj[v1].pHead = s;
 36     }
 37     else
 38     {
 39         struct Node* p = adj[v1].pHead;
 40         struct Node* pr = NULL;
 41         while (p != NULL)
 42         {
 43             if (p->sub == v2)//已存在，无需插入，修改权值
 44             {
 45                 InsertFlag = false;
 46                 p->weight = w;
 47                 return;
 48             }
 49             pr = p;
 50             p = p->pNext;
 51         }
 52         pr->pNext = s;
 53     }
 54 }
 55 void Insert(AdjList adj, NumType v1, NumType v2, WeightType w)
 56 {
 57     InsertFlag = true;//成功插入边
 58     Insert_(adj, v1, v2, w);
 59     Insert_(adj, v2, v1, w);
 60     if (InsertFlag)
 61     {
 62         ++EdgeCnt;
 63         edge[++r].u = v1;
 64         edge[r].v = v2;
 65         edge[r].w = w;
 66      }
 67 }
 68 NumType min[];//存储在最小生成树内的点的编号
 69 bool visited[MAX][MAX];
 70 WeightType prim(AdjList G)//返回最小边权和
 71 {
 72     WeightType ret = 0;//最小和
 73     WeightType dis[MAX];//各点到最小生成树的距离
 74     fill(dis, dis + MAX, INFINITE);//初始化为INFINITE
 75     dis[0] = 0;
 76     struct Node* p = G[0].pHead;
 77     while (p != NULL)
 78     {
 79         dis[p->sub] = p->weight;//把与0相接的点距离0点的距离放入dis
 80         p = p->pNext;
 81     }
 82 
 83     for (int i = 0; i < MAX-1; ++i)//循环MAX次
 84     {
 85         WeightType min = INFINITE;
 86         int k = -1;//存储最小dis的下标
 87         for (int j = 0; j < MAX; ++j)//找出最小dis
 88         {
 89             if (dis[j] != 0 && dis[j] < min)
 90             {
 91                 min = dis[j];
 92                 k = j;
 93             }
 94         }
 95        if (k == -1) return -1;//不连通
 96         ret += min;//更新边权和
 97         dis[k] = 0;//k纳入最小生成树
 98         WeightType temp[MAX];//存储k与相接点的权
 99         fill(temp, temp + MAX, INFINITE);
100         p = G[k].pHead;
101         while (p != NULL)
102         {
103             temp[p->sub] = p->weight;
104             p = p->pNext;
105         }
106         for (int i = 0; i < MAX; ++i)//如果未访问点dis值由于k的纳入变得更小，则更新
107         {
108             if (dis[i] != 0 && temp[i] != INFINITE && temp[i] < dis[i])
109                 dis[i] = temp[i];
110         }
111     }
112     return ret;
113 }
114 //-----------------------Kruskal------------------------
115 NumType root[MAX];
116 NumType FindRoot(NumType x)
117 {
118     NumType t = x;
119     while (root[x] != x)
120     {
121         x = root[x];
122     }
123     return x;
124 }
125 WeightType kruskal(AdjList G)
126 {
127     WeightType ret = 0;
128     int EdgeNum = 0;
129     for (int i = 0; i < EdgeCnt; ++i)//排序
130     {
131         for (int j = 1; j < EdgeCnt; ++j)
132         {
133              if (edge[j].w < edge[j - 1].w)
134             {
135                 struct Edge temp = edge[j];
136                 edge[j] = edge[j - 1];
137                 edge[j - 1] = temp;
138             }
139         }
140     }
141 
142     for (int i = 0; i < EdgeCnt; ++i)
143     {
144         NumType ru = FindRoot(edge[i].u);
145         NumType rv = FindRoot(edge[i].v);
146         if (ru != rv)
147         {
148             root[ru] = rv;//合并集合
149             ret += edge[i].w;
150             ++EdgeNum;
151             if (EdgeNum == MAX - 1) break;//变数为结点数-1，说明生成树构造完成
152         }
153     }
154     if (EdgeNum != MAX - 1) return -1;//图不连通
155     return ret;
156 }
157 
158 int main()
159 {
160     AdjList G;
161     for (int i = 0; i < MAX; ++i)
162         G[i].pHead = NULL;
163     for (int i = 0; i < MAX; ++i)
164         root[i] = i;
165     //构造图
166     Insert(G, 0, 1, 4);
167     Insert(G, 0, 4, 1);
168     Insert(G, 0, 5, 2);
169     Insert(G, 1, 5, 3);
170     Insert(G, 2, 1, 6);
171     Insert(G, 2, 3, 6);
172     Insert(G, 2, 5, 5);
173     Insert(G, 3, 5, 5);
174     Insert(G, 3, 4, 4);
175     Insert(G, 4, 5, 3);
176 
177     cout << "Prim：" << prim(G) <<endl;
178 
179     cout << "Kruskal：" << kruskal(G) << endl;
180 
181     return 0;
182 }

View Code

实验四：

最短路径

Dijkstra：

  1 #include <iostream>
  2 using namespace std;
  3 const int INFINITE = 65535;
  4 const int N = 10;
  5 int pre[N];
  6 int r = -1;
  7 int G[N][N];
  8 void Dijkstra(int(*G)[N], int start, int dis[])
  9 {
 10     bool visited[N];
 11     for (int i = 0; i < N; ++i) dis[i] = G[start][i];
 12     dis[start] = 0;
 13     for (int i = 0; i < N; ++i) visited[i] = false;
 14     visited[start] = true;
 15     for (int i = 0; i < N; ++i)
 16     {
 17         dis[i] = G[start][i];
 18         pre[i] = start;
 19     }
 20     dis[start] = 0;
 21     for (int i = 0; i < N; ++i)
 22     {
 23         int min = INFINITE;
 24         int k = 0;
 25         for (int j = 0; j < N; ++j)
 26         {
 27             if (dis[j] < min && visited[j] == false)
 28             {
 29                 min = dis[j];
 30                 k = j;
 31             }
 32         }
 33         visited[k] = true;
 34         for (int v = 0; v < N; ++v)
 35         {
 36             if (dis[k] + G[k][v] < dis[v] && visited[v] == false)
 37             {
 38                 dis[v] = dis[k] + G[k][v];
 39                 pre[v] = k;
 40             }
 41 
 42         }
 43     }
 44 }
 45 void set(int i, int j, int w)
 46 {
 47     G[i][j] = G[j][i] = w;
 48 }
 49 int main()
 50 {
 51     for (int i = 0; i < N; ++i)
 52         for (int j = 0; j < N; ++j)
 53             G[i][j] = INFINITE;
 54     set(0, 1, 50);
 55     set(0, 5, 1);
 56     set(0, 8, 18);
 57     set(1, 5, 7);
 58     set(1, 2, 5);
 59     set(2, 5, 2);
 60     set(2, 3, 7);
 61     set(2, 6, 10);
 62     set(3, 4, 8);
 63     set(3, 7, 1);
 64     set(3, 6, 10);
 65     set(4, 7, 1);
 66     set(5, 6, 1);
 67     set(5, 8, 15);
 68     set(6, 8, 5);
 69     set(6, 7, 1);
 70     set(6, 9, 3);
 71     set(8, 9, 1);
 72     set(7, 9, 1);
 73     int dis[N];//start到其余点的距离
 74     int start = 0;
 75     Dijkstra(G, start, dis);
 76 
 77     for (int i = 0; i < N; ++i)
 78     {
 79         if (i == start)continue;
 80         cout << start << "到" << i << "的最短路径长度：" << dis[i] << " ";
 81         cout << "路径：";
 82         int out[N];
 83         int rOut = -1;
 84         int e = i;
 85         while (e != start)
 86         {
 87             out[++rOut] = e;
 88             e = pre[e];
 89         }
 90         out[++rOut] = start;
 91         bool outFirst = true;
 92         while (rOut != -1)
 93         {
 94             if (!outFirst)
 95                 cout << "->";
 96             cout << out[rOut--];
 97             outFirst = false;
 98         }
 99         cout << endl;
100     }
101     return 0;
102

View Code

实验五

最短路径

Floyd：

 1 #include <iostream>
 2 using namespace std;
 3 const int INFINITE = 65535;
 4 const int N = 10;
 5 int G[N][N];
 6 int pre[N];
 7 int r = -1;
 8 int dis[N][N];
 9 int path[N][N];//保存路径
10 void Floyd(int(*G)[N])
11 {
12     for (int i = 0; i < N; ++i)
13         for (int j = 0; j < N; ++j)
14         {
15             dis[i][j] = G[i][j];
16             path[i][j] = j;
17         }
18 
19     for (int i = 0; i < N; ++i)
20         dis[i][i] = 0;
21     for(int k=0; k<N; ++k)
22         for(int i=0; i<N; ++i)
23             for (int j = 0; j < N; ++j)
24             {
25                 if (dis[i][k] != INFINITE && dis[k][j] != INFINITE && dis[i][k] + dis[k][j] < dis[i][j])
26                 {
27                     dis[i][j] = dis[i][k] + dis[k][j];
28                     path[i][j] = path[i][k];
29                 }
30             }
31 }
32 void print(int s, int e)
33 {
34     int t = path[s][e];
35     cout << "->" << t;
36     if (t == e) return;
37     print(t, e);
38 }
39 void Print(int s, int e)
40 {
41     cout << s;
42     print(s, e);
43 }
44 void set(int i, int j,int w)
45 {
46     G[i][j] = G[j][i] = w;
47 }
48 int main()
49 {
50     for (int i = 0; i < N; ++i)
51         for (int j = 0; j < N; ++j)
52             G[i][j] = INFINITE;
53     set(0, 1, 50);
54     set(0, 5, 1);
55     set(0, 8, 18);
56     set(1, 5, 7);
57     set(1, 2, 5);
58     set(2, 5, 2);
59     set(2, 3, 7);
60     set(2, 6, 10);
61     set(3, 4, 8);
62     set(3, 7, 1);
63     set(3, 6, 10);
64     set(4, 7, 1);
65     set(5, 6, 1);
66     set(5, 8, 15);
67     set(6, 8, 5);
68     set(6, 7, 1);
69     set(6, 9, 3);
70     set(8, 9, 1);
71     set(7, 9, 1);
72     Floyd(G);
73 
74     for (int i = 0; i < N; ++i)
75     {
76         for (int j = 0; j < N; ++j)
77         {
78             cout << i << "到" << j << "最短路径长度：" << dis[i][j] << endl;
79             cout << "路径为：";
80             Print(i, j);
81             cout << endl;
82         }
83         cout << endl;
84     }
85     return 0;
86 }

View Code

实验六：图的综合应用

  1 #include <iostream>
  2 using namespace std;
  3 const int INFINITE = 65535;
  4 const int MAX = 20;
  5 typedef int WeightType;
  6 typedef int NumType;//结点编号类型
  7 const int N = 17;
  8 int E = 0;//边数
  9 WeightType G[MAX][MAX];
 10 struct Edge
 11 {
 12     NumType u, v;
 13     WeightType w;
 14 };
 15 struct Edge* edge = new struct Edge[N*N];
 16 int rEdge = -1;
 17 void set(int i, int j, WeightType w)
 18 {
 19     if (G[i][j] == INFINITE)
 20     {      
 21         ++E;
 22         edge[++rEdge].u = i;
 23         edge[rEdge].v = j;
 24         edge[rEdge].w = w;
 25     }
 26     G[i][j] = G[j][i] = w;
 27 }
 28 struct Queue
 29 {
 30     int s[MAX];
 31     int r = -1, f = -1;
 32 };
 33 Queue q;
 34 bool inQueue[MAX];
 35 bool VISITED[MAX];
 36 
 37 void DFS(int i)
 38 {
 39     VISITED[i] = true;
 40     for (int j = 0; j < N; ++j)
 41     { 
 42         if (VISITED[j] == false && G[i][j] != INFINITE )
 43         {
 44             cout << "(" << i << "->" << j << ")";
 45             DFS(j);
 46         }
 47     }
 48 }
 49 void BFS(int i)
 50 {
 51     q.s[++q.f] = i;
 52     inQueue[i] = true;
 53     int cnt = 0;
 54     while (q.r < q.f)
 55     {
 56         int n= q.s[++q.r];
 57         if (cnt != 0)cout << "->";
 58             ++cnt;
 59         cout << n;
 60         for (int j = 0; j < N; ++j)
 61         {
 62             if (inQueue[j] == false && G[n][j] != INFINITE)
 63             {
 64                 q.s[++q.f] = j;
 65                 inQueue[j] = true;
 66             }
 67         }
 68     }
 69 }
 70 //Prim
 71 int dis[N];
 72 WeightType Prim()//返回最小边权和
 73 {
 74     WeightType ret = 0;//最小和
 75     WeightType dis[MAX];//各点到最小生成树的距离
 76     fill(dis, dis + MAX, INFINITE);//初始化为INFINITE
 77     dis[0] = 0;//从0开始
 78     for (int i = 1; i < N; ++i)//把与0相接的点距离0点的距离放入dis
 79     {
 80         if (G[0][i] != INFINITE)
 81             dis[i] = G[0][i];
 82     }
 83 
 84     for (int i = 0; i < N - 1; ++i)//循环MAX次
 85     {
 86         WeightType min = INFINITE;
 87         int k = -1;//存储最小dis的下标
 88         for (int j = 0; j < MAX; ++j)//找出最小dis
 89         {
 90             if (dis[j] != 0 && dis[j] < min)
 91             {
 92                 min = dis[j];
 93                 k = j;
 94             }
 95         }
 96         if (k == -1) return -1;//不连通
 97         ret += min;//更新边权和
 98         dis[k] = 0;//k纳入最小生成树
 99         WeightType temp[MAX];//存储k与相接点的权
100         fill(temp, temp + MAX, INFINITE);
101         for (int i = 0; i < N; ++i)
102         {
103             if (temp[i] = G[k][i]);
104         }
105         for (int i = 0; i < MAX; ++i)//如果未访问点dis值由于k的纳入变得更小，则更新
106         {
107             if (dis[i] != 0 && temp[i] != INFINITE && temp[i] < dis[i])
108                 dis[i] = temp[i];
109         }
110     }
111     return ret;
112 }
113 //Kruskal
114 NumType root[MAX];
115 NumType FindRoot(NumType x)
116 {
117     NumType t = x;
118     while (root[x] != x)
119     {
120         x = root[x];
121     }
122     return x;
123 }
124 WeightType Kruskal()
125 {
126     WeightType ret = 0;
127     int EdgeNum = 0;
128     for (int i = 0; i < E; ++i)//排序
129     {
130         for (int j = 1; j < E; ++j)
131         {
132             if (edge[j].w < edge[j - 1].w)
133             {
134                 struct Edge temp = edge[j];
135                 edge[j] = edge[j - 1];
136                 edge[j - 1] = temp;
137             }
138         }
139     }
140     for (int i = 0; i < E; ++i)
141     {
142         NumType ru = FindRoot(edge[i].u);
143         NumType rv = FindRoot(edge[i].v);
144         if (ru != rv)
145         {
146             root[ru] = rv;//合并集合
147             ret += edge[i].w;
148             ++EdgeNum;
149             if (EdgeNum == N - 1) break;//边数为结点数-1，说明生成树构造完成
150         }
151     }
152     if (EdgeNum != N - 1) return -1;//图不连通
153     return ret;
154 }
155 //Dijkstra
156 void Dijkstra(int s)
157 {
158     int pre[N];
159     int dis[N];
160     bool visited[N];
161     for (int i = 0; i < N; ++i) visited[i] = false;
162     visited[s] = true;
163     for (int i = 0; i < N; ++i)
164     {
165         dis[i] = G[s][i];
166         pre[i] = s;
167     }
168     dis[s] = 0;
169     for (int i = 0; i < N; ++i)
170     {
171         int min = INFINITE;
172         int k = 0;
173         for (int j = 0; j < N; ++j)
174         {
175             if (dis[j] < min && visited[j] == false)
176             {
177                 visited[j] = true;
178                 min = dis[j];
179                 k = j;
180             }
181         }
182         for (int v = 0; v < N; ++v)
183         {
184             if (dis[k] + G[k][v] < dis[v])
185             {
186                 dis[v] = dis[k] + G[k][v];
187                 pre[v] = k;
188             }
189         }
190     }
191     for (int i = 0; i < N; ++i)
192     {
193         if (i == s)continue;
194         cout << s << "到" << i << "的最短路径长度：" << dis[i] << " ";
195         cout << "路径：";
196         int out[N];
197         int rOut = -1;
198         int e = i;
199         while (e != s)
200         {
201             out[++rOut] = e;
202             e = pre[e];
203         }
204         out[++rOut] = s;
205         bool outFirst = true;
206         while (rOut != -1)
207         {
208             if (!outFirst)
209                 cout << "->";
210             cout << out[rOut--];
211             outFirst = false;
212         }
213         cout << endl;
214     }
215 }
216 //Floyd
217 int Dis[N][N];
218 int path[N][N];//保存路径
219 void Floyd()
220 {
221     for (int i = 0; i < N; ++i)
222         for (int j = 0; j < N; ++j)
223         {
224             Dis[i][j] = G[i][j];
225             path[i][j] = j;
226         }
227 
228     for (int i = 0; i < N; ++i)
229         Dis[i][i] = 0;
230     for (int k = 0; k < N; ++k)
231         for (int i = 0; i < N; ++i)
232             for (int j = 0; j < N; ++j)
233             {
234                 if (Dis[i][k] != INFINITE && Dis[k][j] != INFINITE && Dis[i][k] + Dis[k][j] < Dis[i][j])
235                 {
236                     Dis[i][j] = Dis[i][k] + Dis[k][j];
237                     path[i][j] = path[i][k];
238                 }
239             }
240 }
241 void print(int s, int e)
242 {
243     int t = path[s][e];
244     cout << "->" << t;
245     if (t == e) return;
246     print(t, e);
247 }
248 void Print(int s, int e)
249 {
250     cout << s;
251     print(s, e);
252 }
253 
254 int main()
255 {
256     for (int i = 0; i < MAX; ++i)
257         for (int j = 0; j < MAX; ++j)
258             G[i][j] = (i==j ? 0 : INFINITE);
259     int order;
260     for (int i = 0; i < MAX; ++i)
261         VISITED[i] = false;
262     for (int i = 0; i < MAX; ++i)
263         inQueue[i] = false;
264     for (int i = 0; i < N; ++i)
265         root[i] = i;
266     //构造图
267     set(0, 1, 1); set(0, 14, 1); set(1, 2, 10); set(2, 14, 1); set(14, 13, 1); set(13, 12, 10);
268     set(2, 3, 10); set(12, 16, 1); set(3, 4, 1); set(11, 4, 1); set(16, 10, 1); set(15, 10, 1);
269     set(10, 9, 20); set(11, 9, 1); set(15, 7, 1); set(5, 7, 1); set(5, 6, 10); set(6, 9, 1);
270     set(4, 8, 1); set(2, 7, 1); set(4, 5, 1);
271     cout << "选择功能" << endl
272         << "1.使用DFS遍历输出图" << endl
273         << "2.使用BFS遍历输出图" << endl
274         << "3.求最小生成树（Prim算法）" << endl
275         << "4.求最小生成树（Kruskal算法）" << endl
276         << "5.求点s到其余点的最短路径（Dijkstra算法）" << endl
277         << "6.求各点间的最短路径（Floyd算法）" << endl;
278     
279     while (cin >> order)
280     {
281         if (order == 1)//dfs
282         {
283             cout << "输入起点：";
284             int s;
285             cin >> s;
286             DFS(s);
287         }
288         if (order == 2)//bfs
289         {
290             cout << "输入起点：";
291             int s;
292             cin >> s;
293             BFS(s);
294         }
295         if (order == 3)
296         {
297             cout << "最小生成树边权和(Prim)："<<Prim();
298         }
299         if (order == 4)
300         {
301             cout << "最小生成树边权和(Kruskal)：" << Kruskal();
302         }
303         if (order == 5)
304         {
305             cout << "输入点s编号：";
306             int s;
307             cin >> s;
308             Dijkstra(s);
309         }
310         if (order == 6)
311         {
312             Floyd();
313             for (int i = 0; i < N; ++i)
314             {
315                 for (int j = 0; j < N; ++j)
316                 {
317                     cout << i << "到" << j << "最短路径长度：" << Dis[i][j] << endl;
318                     cout << "路径为：";
319                     Print(i, j);
320                     cout << endl;
321                 }
322                 cout << endl;
323             }
324         }
325         cout << endl << "已完成,请输入：";
326     }
327 
328         
329     return 0;
330

  1 #include <iostream>
  2 using namespace std;
  3 const int INFINITE = 65535;
  4 const int MAX = 20;
  5 typedef int WeightType;
  6 typedef int NumType;//结点编号类型
  7 const int N = 17;
  8 int E = 0;//边数
  9 WeightType G[MAX][MAX];
 10 struct Edge
 11 {
 12     NumType u, v;
 13     WeightType w;
 14 };
 15 struct Edge* edge = new struct Edge[N * N];
 16 int rEdge = -1;
 17 void set(int i, int j, WeightType w)
 18 {
 19     if (G[i][j] == INFINITE)
 20     {
 21         ++E;
 22         edge[++rEdge].u = i;
 23         edge[rEdge].v = j;
 24         edge[rEdge].w = w;
 25     }
 26     G[i][j] = G[j][i] = w;
 27 }
 28 struct Queue
 29 {
 30     int s[MAX];
 31     int r = -1, f = -1;
 32 };
 33 Queue q;
 34 bool inQueue[MAX];
 35 bool VISITED[MAX];
 36 
 37 void DFS(int i)
 38 {
 39     VISITED[i] = true;
 40     for (int j = 0; j < N; ++j)
 41     {
 42         if (VISITED[j] == false && G[i][j] != INFINITE)
 43         {
 44             cout << "(" << i << "->" << j << ")";
 45             DFS(j);
 46         }
 47     }
 48 }
 49 void BFS(int i)
 50 {
 51     q.s[++q.f] = i;
 52     inQueue[i] = true;
 53     int cnt = 0;
 54     while (q.r < q.f)
 55     {
 56         int n = q.s[++q.r];
 57         if (cnt != 0)cout << "->";
 58         ++cnt;
 59         cout << n;
 60         for (int j = 0; j < N; ++j)
 61         {
 62             if (inQueue[j] == false && G[n][j] != INFINITE)
 63             {
 64                 q.s[++q.f] = j;
 65                 inQueue[j] = true;
 66             }
 67         }
 68     }
 69 }
 70 //Prim
 71 int dis[N];
 72 WeightType Prim()//返回最小边权和
 73 {
 74     WeightType ret = 0;//最小和
 75     WeightType dis[MAX];//各点到最小生成树的距离
 76     fill(dis, dis + MAX, INFINITE);//初始化为INFINITE
 77     dis[0] = 0;//从0开始
 78     for (int i = 1; i < N; ++i)//把与0相接的点距离0点的距离放入dis
 79     {
 80         if (G[0][i] != INFINITE)
 81             dis[i] = G[0][i];
 82     }
 83 
 84     for (int i = 0; i < N - 1; ++i)//循环MAX次
 85     {
 86         WeightType min = INFINITE;
 87         int k = -1;//存储最小dis的下标
 88         for (int j = 0; j < MAX; ++j)//找出最小dis
 89         {
 90             if (dis[j] != 0 && dis[j] < min)
 91             {
 92                 min = dis[j];
 93                 k = j;
 94             }
 95         }
 96         if (k == -1) return -1;//不连通
 97         ret += min;//更新边权和
 98         dis[k] = 0;//k纳入最小生成树
 99         WeightType temp[MAX];//存储k与相接点的权
100         fill(temp, temp + MAX, INFINITE);
101         for (int i = 0; i < N; ++i)
102         {
103             if (temp[i] = G[k][i]);
104         }
105         for (int i = 0; i < MAX; ++i)//如果未访问点dis值由于k的纳入变得更小，则更新
106         {
107             if (dis[i] != 0 && temp[i] != INFINITE && temp[i] < dis[i])
108                 dis[i] = temp[i];
109         }
110     }
111     return ret;
112 }
113 //Kruskal
114 NumType root[MAX];
115 NumType FindRoot(NumType x)
116 {
117     NumType t = x;
118     while (root[x] != x)
119     {
120         x = root[x];
121     }
122     return x;
123 }
124 WeightType Kruskal()
125 {
126     WeightType ret = 0;
127     int EdgeNum = 0;
128     for (int i = 0; i < E; ++i)//排序
129     {
130         for (int j = 1; j < E; ++j)
131         {
132             if (edge[j].w < edge[j - 1].w)
133             {
134                 struct Edge temp = edge[j];
135                 edge[j] = edge[j - 1];
136                 edge[j - 1] = temp;
137             }
138         }
139     }
140     for (int i = 0; i < E; ++i)
141     {
142         NumType ru = FindRoot(edge[i].u);
143         NumType rv = FindRoot(edge[i].v);
144         if (ru != rv)
145         {
146             root[ru] = rv;//合并集合
147             ret += edge[i].w;
148             ++EdgeNum;
149             if (EdgeNum == N - 1) break;//边数为结点数-1，说明生成树构造完成
150         }
151     }
152     if (EdgeNum != N - 1) return -1;//图不连通
153     return ret;
154 }
155 //Dijkstra
156 void Dijkstra(int s)
157 {
158     int pre[N];
159     int dis[N];
160     bool visited[N];
161     for (int i = 0; i < N; ++i) visited[i] = false;
162     visited[s] = true;
163     for (int i = 0; i < N; ++i)
164     {
165         dis[i] = G[s][i];
166         pre[i] = s;
167     }
168     dis[s] = 0;
169     while (1)
170     {
171         int min = INFINITE;
172         int k = 0;
173         for (int j = 0; j < N; ++j)
174         {
175             if (dis[j] < min && visited[j] == false)
176             {
177                 min = dis[j];
178                 k = j;
179             }
180         }
181         visited[k] = true;
182         if (min == INFINITE)break;
183         for (int v = 0; v < N; ++v)
184         {
185             if (dis[k] + G[k][v] < dis[v] && visited[v] == false )
186             {
187                 dis[v] = dis[k] + G[k][v];
188                 pre[v] = k;
189             }
190         }
191     }
192     for (int i = 0; i < N; ++i)
193     {
194         if (i == s)continue;
195         cout << s << "到" << i << "的最短路径长度：" << dis[i] << " ";
196         cout << "路径：";
197         int out[N];
198         int rOut = -1;
199         int e = i;
200         while (e != s)
201         {
202             out[++rOut] = e;
203             e = pre[e];
204         }
205         out[++rOut] = s;
206         bool outFirst = true;
207         while (rOut != -1)
208         {
209             if (!outFirst)
210                 cout << "->";
211             cout << out[rOut--];
212             outFirst = false;
213         }
214         cout << endl;
215     }
216 }
217 //Floyd
218 int Dis[N][N];
219 int path[N][N];//保存路径
220 void Floyd()
221 {
222     for (int i = 0; i < N; ++i)
223         for (int j = 0; j < N; ++j)
224         {
225             Dis[i][j] = G[i][j];
226             path[i][j] = j;
227         }
228 
229     for (int i = 0; i < N; ++i)
230         Dis[i][i] = 0;
231     for (int k = 0; k < N; ++k)
232         for (int i = 0; i < N; ++i)
233             for (int j = 0; j < N; ++j)
234             {
235                 if (Dis[i][k] != INFINITE && Dis[k][j] != INFINITE && Dis[i][k] + Dis[k][j] < Dis[i][j])
236                 {
237                     Dis[i][j] = Dis[i][k] + Dis[k][j];
238                     path[i][j] = path[i][k];
239                 }
240             }
241 }
242 void print(int s, int e)
243 {
244     int t = path[s][e];
245     cout << "->" << t;
246     if (t == e) return;
247     print(t, e);
248 }
249 void Print(int s, int e)
250 {
251     cout << s;
252     print(s, e);
253 }
254 
255 int main()
256 {
257     for (int i = 0; i < MAX; ++i)
258         for (int j = 0; j < MAX; ++j)
259             G[i][j] = (i == j ? 0 : INFINITE);
260     int order;
261     //构造图
262     set(0, 1, 1); set(0, 14, 1); set(1, 2, 10); set(2, 14, 1); set(14, 13, 1); set(13, 12, 10);
263     set(2, 3, 10); set(12, 16, 1); set(3, 4, 1); set(11, 4, 1); set(16, 10, 1); set(15, 10, 1);
264     set(10, 9, 20); set(11, 9, 1); set(15, 7, 1); set(5, 7, 1); set(5, 6, 10); set(6, 9, 1);
265     set(4, 8, 1); set(2, 7, 1); set(4, 5, 1);
266     cout << "选择功能" << endl
267         << "1.使用DFS遍历输出图" << endl
268         << "2.使用BFS遍历输出图" << endl
269         << "3.求最小生成树（Prim算法）" << endl
270         << "4.求最小生成树（Kruskal算法）" << endl
271         << "5.求点s到其余点的最短路径（Dijkstra算法）" << endl
272         << "6.求各点间的最短路径（Floyd算法）" << endl;
273 
274     while (cin >> order)
275     {
276         if (order == 1)//dfs
277         {
278             for (int i = 0; i < MAX; ++i)
279                 VISITED[i] = false;
280             cout << "输入起点：";
281             int s;
282             cin >> s;
283             DFS(s);
284         }
285         if (order == 2)//bfs
286         {
287             for (int i = 0; i < MAX; ++i)
288                 inQueue[i] = false;
289             q.f = q.r = -1;
290             cout << "输入起点：";
291             int s;
292             cin >> s;
293             BFS(s);
294         }
295         if (order == 3)
296         {
297             cout << "最小生成树边权和(Prim)：" << Prim();
298         }
299         if (order == 4)
300         {
301             for (int i = 0; i < N; ++i)
302                 root[i] = i;
303             cout << "最小生成树边权和(Kruskal)：" << Kruskal();
304         }
305         if (order == 5)
306         {
307             cout << "输入点s编号：";
308             int s;
309             cin >> s;
310             Dijkstra(s);
311         }
312         if (order == 6)
313         {
314             Floyd();
315             for (int i = 0; i < N; ++i)
316             {
317                 for (int j = 0; j < N; ++j)
318                 {
319                     cout << i << "到" << j << "最短路径长度：" << Dis[i][j] << endl;
320                     cout << "路径为：";
321                     Print(i, j);
322                     cout << endl;
323                 }
324                 cout << endl;
325             }
326         }
327         cout << endl << "已完成,请输入：";
328     }
329 
330 
331     return 0;
332 }

View Code

实验八：

多线程

哲学家就餐

问题：

  1 #include <stdio.h>
  2 #include <pthread.h>
  3 #include <semaphore.h>
  4 #define N 5//number of philosofer
  5 #define LEFT i
  6 #define RIGHT (i+1)%N
  7 sem_t chopstick[N];
  8 sem_t four;
  9 sem_t one;
 10 pthread_t thread[N];
 11 int philosopher[N];//their number
 12 int func_num = 0;
 13 void thinking(int i)
 14 {
 15     printf("philosopher %d is thingking(func%d)
", i + 1, func_num);
 16     sleep(1);
 17 }
 18 void eating(int i)
 19 {
 20     printf("philosopher %d is eating(func%d)
", i + 1, func_num);
 21     sleep(1);
 22 }
 23 void* func1(void* param)//初始方法
 24 {
 25     int i = *((int*)param);
 26     while (1)
 27     {
 28         thinking(i);
 29         sem_wait(&chopstick[LEFT]);
 30         sem_wait(&chopstick[RIGHT]);
 31         eating(i);
 32         sem_post(&chopstick[LEFT]);
 33         sem_post(&chopstick[RIGHT]);
 34         thinking(1);
 35     }
 36     pthread_exit(NULL);
 37 }
 38 void* func2(void* param)//不对称的方法
 39 {
 40     int i = *((int*)param);
 41     while (1)
 42     {
 43         thinking(i);
 44         if (i % 2 == 0)
 45         {
 46             sem_wait(&chopstick[LEFT]);
 47             sem_wait(&chopstick[RIGHT]);
 48             eating(i);
 49             sem_post(&chopstick[RIGHT]);
 50             sem_post(&chopstick[LEFT]);
 51         }
 52         else
 53         {
 54             sem_wait(&chopstick[RIGHT]);
 55             sem_wait(&chopstick[LEFT]);
 56             eating(i);
 57             sem_post(&chopstick[LEFT]);
 58             sem_post(&chopstick[RIGHT]);
 59         }
 60         thinking(i);
 61     }
 62     pthread_exit(NULL);
 63 }
 64 void* func3(void* param)//最多4个哲学家同时就餐
 65 {
 66     int i = *((int*)param);
 67     while (1)
 68     {
 69         thinking(i);
 70         sem_wait(&four);
 71         sem_wait(&chopstick[LEFT]);
 72         sem_wait(&chopstick[RIGHT]);
 73         eating(i);
 74         sem_post(&chopstick[RIGHT]);
 75         sem_post(&chopstick[LEFT]);
 76         sem_post(&four);
 77         thinking(i);
 78     }
 79     pthread_exit(NULL);
 80 }
 81 void* func4(void* param)//只有当左右筷子都可用时才拿起筷子
 82 {
 83     int i = *((int*)param);
 84     while (1)
 85     {
 86         thinking(i);
 87         sem_wait(&one);
 88         sem_wait(&chopstick[LEFT]);
 89         sem_wait(&chopstick[RIGHT]);
 90         sem_post(&one);
 91         eating(i);
 92         sem_post(&chopstick[RIGHT]);
 93         sem_post(&chopstick[LEFT]);
 94         thinking(i);
 95     }
 96     pthread_exit(NULL);
 97 }
 98 void thread_create()
 99 {
100     int t;
101     for (int i = 0; i < N; ++i)
102     {
103         //t=pthread_create(&thread[i],NULL,func1,&philosopher[i]); func_num = 1;
104         //t=pthread_create(&thread[i],NULL,func2,&philosopher[i]); func_num = 2;
105             //t=pthread_create(&thread[i],NULL,func3,&philosopher[i]); func_num = 3;
106         t = pthread_create(&thread[i], NULL, func4, &philosopher[i]); func_num = 4;
107         if (t != 0)
108             printf("failed in creating thread%d
", i);
109     }
110 }
111 thread_wait()
112 {
113     for (int i = 0; i < N; ++i)
114     {
115         pthread_join(thread[i], NULL);
116         printf("thread %d is ended", i);
117     }
118 }
119 int main()
120 {
121     for (int i = 0; i < N; ++i)
122     {
123         sem_init(&chopstick[i], 0, 1);
124         philosopher[i] = i;
125     }
126     sem_init(&four, 0, 4);
127     sem_init(&one, 0, 4);
128     thread_create();
129     thread_wait();
130     return 0;
131 }

View Code

多线程共享资源：多个线程共享变量sum

 1 #include <stdio.h>
 2 #include <pthread.h>
 3 #include<time.h>
 4 #include <semaphore.h>
 5 #define N 10
 6 pthread_t thread[100];
 7 unsigned long int sum=0;
 8 
 9 void count(void *param)
10 {    
11     int i = *((int*)param);
12     while(1)
13     {
14     if(sum == 1024)break;        
15     sum += 1;
16     printf("thread%d: sum = %d
", i,sum);
17     }
18 }
19 void thread_create()
20 {
21     int t;
22     for(int i=0; i<N; ++i)
23     {
24           t=pthread_create(&thread[i],NULL,count, &i);
25         if(t != 0)
26         {
27               printf("failed in creating thread%d
",i);
28         }
29     }
30 }
31 thread_wait()
32 {
33     for(int i=0; i<N; ++i)
34     {
35         pthread_join(thread[i],NULL);
36         printf("thread %d is ended
", i);
37     }
38 }
39 int main()
40 {
41    thread_create();
42    thread_wait();
43     return 0;
44 }

View Code

实验九：　　

1、设计并实现操作系统读者写者问题读者优先算法。

只要有一个读者在读，其他读者就无需等待

为什么？因为如果有读者了，说明在读写者的竞争中，读者得到了资源，后面来的读者就可以直接读了

2、设计并实现操作系统读者写者问题写者优先算法。

放一起：

  1 #include <stdio.h>
  2 #include <pthread.h>
  3 #include <semaphore.h>
  4 #define N_reader 3
  5 #define N_writer 3
  6 pthread_t reader_thread[3], writer_thread[3];
  7 struct student
  8 {
  9     char name[10];
 10     int id;
 11 };
 12 struct student idr[N_reader], idw[N_writer];
 13 int read_count = 0;
 14 int write_count = 0;
 15 sem_t  mutex;
 16 sem_t rcnt_mutex;
 17 sem_t wcnt_mutex;
 18 sem_t rw_mutex;//读者-写者、写者-写者之间的互斥，
 19 sem_t r_mutex;
 20 sem_t w_mutex;
 21 sem_t out_mutex;
 22 void reading(int i)
 23 {
 24     printf("reader%d is reading2
",i);
 25 
 26 }
 27 void writing(int i)
 28 {
 29     printf("writer%d is writng2
",i);
 30 }
 31 //--------------读者优先-----------------
 32 void* read1(void *param)
 33 {
 34     int i = *((int*)param);
 35     while(1)
 36     {
 37         sem_wait(&mutex);
 38         ++read_count;
 39         if(read_count == 1)
 40             sem_wait(&rw_mutex);
 41         sem_post(&mutex);
 42         reading(i);
 43         sem_wait(&mutex);
 44         --read_count;
 45         if(read_count == 0)
 46             sem_post(&rw_mutex);
 47         sem_post(&mutex);
 48 sleep(1);
 49     }
 50     pthread_exit(NULL);
 51 }
 52 void* write1(void *param)
 53 {
 54     int i = *((int*)param);
 55     while(1)
 56     {
 57         sem_wait(&rw_mutex);
 58         writing(i);
 59         sem_post(&rw_mutex);
 60     sleep(1);
 61     }
 62     pthread_exit(NULL);
 63 }
 64 //--------------写者优先-----------------
 65 void read2(void *param)
 66 {
 67     int i = *((int*)param);
 68     while(1)
 69     {
 70     sem_wait(&out_mutex);
 71         sem_wait(&r_mutex);//只有在写完成后才能获得r_mutex
 72 
 73         sem_wait(&rcnt_mutex);
 74             ++read_count;
 75         if(read_count == 1)
 76             sem_wait(&w_mutex);//如果是第一个读者，上w_mutex，防止读的时候写入，可以多个读者同时读
 77         sem_post(&rcnt_mutex);
 78         sem_post(&r_mutex);
 79     sem_post(&out_mutex);
 80 
 81         reading(i);
 82 
 83         sem_wait(&rcnt_mutex);
 84             --read_count;
 85         if(read_count == 0)
 86             sem_post(&w_mutex);//读完之后，释放w_mutex
 87         sem_post(&rcnt_mutex);
 88 
 89 
 90         sleep(1);
 91     }
 92     pthread_exit(NULL);
 93 }
 94 void write2(void *param)
 95 {
 96     int i = *((int*)param);
 97     while(1)
 98     {
 99         sem_wait(&wcnt_mutex);
100             ++write_count;
101         if(write_count == 1)
102             sem_wait(&r_mutex);//上r_mutex，防止读者进入队列
103         sem_post(&wcnt_mutex);
104 
105         sem_wait(&w_mutex);//与其他写操作互斥
106         writing(i);
107         sem_post(&w_mutex);
108 
109         sem_wait(&wcnt_mutex);
110             --write_count;
111         if(write_count == 0)
112             sem_post(&r_mutex);//只有当所有写者完成操作，才释放r_mutex
113         sem_post(&wcnt_mutex);
114         
115         sleep(1);
116     }
117     pthread_exit(NULL);
118 }
119 void thread_create()
120 {
121     int t;
122     for(int i=0; i<N_writer; ++i)
123     {
124         t=pthread_create(&writer_thread[i],NULL,write2,&idw[i].id);
125         if(t != 0)
126         {
127         printf("failed in creating thread%d
",i);
128         }
129     }
130     for(int i=0; i<N_reader; ++i)
131     {
132         t=pthread_create(&reader_thread[i],NULL,read2,&idr[i].id);
133         if(t != 0)
134         {
135         printf("failed in creating thread%d
",i);
136         }
137     }
138 }
139 thread_wait()
140 {
141     for(int i=0; i<N_reader; ++i)
142     {
143         pthread_join(reader_thread[i],NULL);
144         printf("reader_thread %d is ended
", i);
145     }
146     for(int i=0; i<N_writer; ++i)
147     {
148         pthread_join(writer_thread[i],NULL);
149         printf("writer_thread %d is ended
", i);
150     }
151 }
152 int main()
153 {
154     sem_init(&mutex,0,1);
155     sem_init(&rw_mutex,0,1);
156     sem_init(&r_mutex,0,1);
157     sem_init(&w_mutex,0,1);
158     sem_init(&rcnt_mutex,0,1);
159     sem_init(&wcnt_mutex,0,1);
160     sem_init(&out_mutex,0,1);
161     for(int i=0; i<N_reader+N_writer; ++i)
162     {
163            idr[i].id = i+1;
164         idw[i].id = i+1;
165     }
166     thread_create();
167     thread_wait();
168     return 0;
169 }

View Code

末尾有“2”的为写者优先的程序运行结果

实验十：

 1 #include <stdio.h>
 2 #include <pthread.h>
 3 #include <unistd.h>
 4 #include <semaphore.h>
 5 #define N 10
 6 pthread_t thread[N];
 7 bool choosing[N];
 8 int number[N];
 9 
10 void process(int i) {
11     while (1) {
12         // 当前进程i正在取号
13         choosing[i] = true;
14         // number为上一个已发放的排队号加1
15         int max = 0;
16         for (int k = 0; k < i - 1; ++k)
17         {
18             if (number[k] > max)
19                 max = number[k];
20         }
21         number[i] = 1 + max;
22         // 当前进程i取号完毕
23         choosing[i] = false;
24         // 迭代所有进程
25         for (j = 0; j < N;  ++j)
26         {
27             // 若当前迭代到的进程j正在取号，则等待其取号完毕
28             while (choosing[j]);
29             // 同时满足，当前进程才能通过
30             while (number[j] != 0 && ((number[j] < number[i]) || ((number[j] == number[i]) && j < i)));
31         }
32         // 临界区代码
33         printf("thread %d, number[i] = %d
", i, number[i]);
34         // 当前进程注销排队号
35         // 一旦线程在临界区执行完毕，需要把自己的排队签到号码置为0，表示处于非临界区
36         number[i] = 0;
37 
38         // 其它代码
39     }
40 }
41 
42 void thread_create() { //进程创建
43     int t;
44     for (int i = 0; i < N; ++i) {
45         tmp = pthread_create(&thread[i], NULL, process, &i);
46         if (tmp != 0) {
47             printf("线程%d创建失败
", i);
48         }
49     }
50 }
51 void thread_wait() {
52     for (int i = 0; i < N; ++i) {
53         pthread_join(thread[i], NULL);
54         printf("线程%d结束
", i);
55     }
56 }
57 int main()
58 {
59     number[0] = 1;
60     thread_create();
61     thread_wait();
62     for(int )
63     return 0;
64 }

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <unistd.h>
  4 #include <sys/types.h>
  5 #include <pthread.h>
  6 #include <assert.h>
  7 /*
  8 *线程池里所有运行和等待的任务都是一个CThread_worker（即struct worker）
  9 *由于所有任务都在链表里，所以是一个链表结构
 10 */
 11 typedef struct worker
 12 {
 13     /*回调函数，任务运行时会调用此函数，注意也可声明成其它形式*/
 14     void *(*process) (void *arg);
 15     void *arg;/*回调函数的参数*/
 16     struct worker *next;
 17 } CThread_worker;
 18 
 19 /*线程池结构*/
 20 typedef struct
 21 {
 22     pthread_mutex_t queue_lock;//互斥锁
 23     pthread_cond_t queue_ready;//触发条件
 24     /*链表结构，线程池中所有等待任务*/
 25     CThread_worker *queue_head;
 26     /*是否销毁线程池*/
 27     int shutdown;
 28     pthread_t *threadid;
 29     /*线程池中允许的活动线程数目*/
 30     int max_thread_num;
 31     /*当前等待队列的任务数目*/
 32     int cur_queue_size;
 33 } CThread_pool;
 34 
 35 int pool_add_worker (void *(*process) (void *arg), void *arg);
 36 void *thread_routine (void *arg);//线程要执行的函数
 37 
 38 static CThread_pool *pool = NULL;
 39 void pool_init (int max_thread_num)//初始化线程池
 40 {
 41     pool = (CThread_pool *) malloc (sizeof (CThread_pool));
 42     pthread_mutex_init (&(pool->queue_lock), NULL);//被初始化为未锁住状态
 43     pthread_cond_init (&(pool->queue_ready), NULL);
 44     pool->queue_head = NULL;
 45     pool->max_thread_num = max_thread_num;
 46     pool->cur_queue_size = 0;
 47     pool->shutdown = 0;
 48     pool->threadid =
 49         (pthread_t *) malloc (max_thread_num * sizeof (pthread_t));
 50     int i = 0;
 51     for (i = 0; i < max_thread_num; i++)
 52     { 
 53         pthread_create (&(pool->threadid[i]), NULL, thread_routine,
 54                 NULL);//创建线程
 55     }
 56 }
 57 /*向线程池中加入任务，然后唤醒一个等待中的线程（如果有的话）*/
 58 int pool_add_worker (void *(*process) (void *arg), void *arg)
 59 {
 60     /*构造一个新任务*/
 61     CThread_worker *newworker = (CThread_worker *) malloc (sizeof (CThread_worker));
 62     newworker->process = process;//要执行的函数
 63     newworker->arg = arg;//函数参数
 64     newworker->next = NULL;/*别忘置空*/
 65     pthread_mutex_lock (&(pool->queue_lock));//将任务加到队列前，要上互斥锁
 66     /*将任务加入到等待队列中*/
 67     CThread_worker *member = pool->queue_head;//member指向任务队列的头
 68     if (member != NULL)//尾插法插入newworker
 69     {
 70         while (member->next != NULL)
 71             member = member->next;
 72         member->next = newworker;
 73     }
 74     else//队列为空
 75     {
 76         pool->queue_head = newworker;//直接插入newworker
 77     }
 78     assert (pool->queue_head != NULL);//表达式pool->queue_head != NULL必须为true
 79     pool->cur_queue_size++;//当前队列数加一
 80     pthread_mutex_unlock (&(pool->queue_lock));//完成添加队列的操作，解互斥锁
 81     /*好了，等待队列中有任务了，唤醒一个等待线程；
 82     注意如果所有线程都在忙碌，这句没有任何作用*/
 83     pthread_cond_signal (&(pool->queue_ready));//触发线程，使其脱离阻塞状态
 84     return 0;
 85 }
 86 
 87 /*销毁线程池，等待队列中的任务不会再被执行，但是正在运行的线程会一直
 88 把任务运行完后再退出*/
 89 int pool_destroy ()
 90 {
 91     if (pool->shutdown)
 92         return -1;/*防止两次调用*/
 93     pool->shutdown = 1;
 94     /*唤醒所有等待线程，线程池要销毁了*/
 95     pthread_cond_broadcast (&(pool->queue_ready));
 96     /*阻塞等待线程退出，否则就成僵尸了*/
 97     int i;
 98     for (i = 0; i < pool->max_thread_num; i++)
 99         pthread_join (pool->threadid[i], NULL);
100     free (pool->threadid);
101     /*销毁等待队列*/
102     CThread_worker *head = NULL;
103     while (pool->queue_head != NULL)
104     {
105         head = pool->queue_head;
106         pool->queue_head = pool->queue_head->next;
107         free (head);
108     }
109     /*条件变量和互斥量也别忘了销毁*/
110     pthread_mutex_destroy(&(pool->queue_lock));
111     pthread_cond_destroy(&(pool->queue_ready));
112     
113     free (pool);
114     /*销毁后指针置空是个好习惯*/
115     pool=NULL;
116     return 0;
117 }
118 
119 void * thread_routine (void *arg)//线程中要执行的函数
120 {
121     printf ("starting thread 0x%x
", pthread_self ());//pthread_self()获得线程自身id
122     while (1)
123     {
124         pthread_mutex_lock (&(pool->queue_lock));
125         /*如果等待队列为0并且不销毁线程池，则处于阻塞状态; 注意
126         pthread_cond_wait是一个原子操作，等待前会解锁，唤醒后会加锁*/
127         while (pool->cur_queue_size == 0 && !pool->shutdown)
128         {
129             printf ("thread 0x%x is waiting
", pthread_self ());
130             pthread_cond_wait (&(pool->queue_ready), &(pool->queue_lock));
131         }
132         /*线程池要销毁了*/
133         if (pool->shutdown)
134         {
135             /*遇到break,continue,return等跳转语句，千万不要忘记先解锁*/
136             pthread_mutex_unlock (&(pool->queue_lock));
137             printf ("thread 0x%x will exit
", pthread_self ());
138             pthread_exit (NULL);
139         }
140         printf ("thread 0x%x is starting to work
", pthread_self ());//线程处理中
141         /*assert是调试的好帮手*/
142         assert (pool->cur_queue_size != 0);
143         assert (pool->queue_head != NULL);
144         
145         /*等待队列长度减去1，并取出链表中的头元素*/
146         pool->cur_queue_size--;
147         CThread_worker *worker = pool->queue_head;
148         pool->queue_head = worker->next;
149         pthread_mutex_unlock (&(pool->queue_lock));
150         /*调用回调函数，执行任务*/
151         (*(worker->process)) (worker->arg);
152         free (worker);
153         worker = NULL;
154     }
155     /*这一句应该是不可达的*/
156     pthread_exit (NULL);
157 }
158 void *
159 myprocess (void *arg)//回调函数
160 {
161     printf ("threadid is 0x%x, working on task %d
", pthread_self (),*(int *) arg);
162     sleep (1);/*休息一秒，延长任务的执行时间*/
163     return NULL;
164 }
165 int main (int argc, char **argv)
166 {
167     pool_init (3);/*线程池中最多三个活动线程*/
168     /*连续向池中投入10个任务*/
169     int *workingnum = (int *) malloc (sizeof (int) * 50);
170     int i;
171     for (i = 0; i < 50; ++i)
172     {
173         workingnum[i] = i;
174         pool_add_worker (myprocess, &workingnum[i]);
175     }
176     /*等待所有任务完成*/
177     sleep (5);
178     /*销毁线程池*/
179     pool_destroy ();
180     free (workingnum);
181     return 0;
182 }

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <unistd.h>
  4 #include <sys/types.h>
  5 #include <pthread.h>
  6 #include <assert.h>
  7 #define bool int
  8 #define true 1
  9 #define false 0
 10 typedef struct worker//任务结构体
 11 {
 12     /*回调函数，任务运行时会调用此函数，注意也可声明成其它形式*/
 13     void* (*process) (void* arg);
 14     void* arg;/*回调函数的参数*/
 15     struct worker* next;
 16 } CThread_worker;
 17 typedef struct PCB
 18  {
 19     pthread_t thread;
 20     int thread_id;//线程名字
 21     int arriveTime;//到达时间
 22     int runTime;//估计运行时间
 23     char status;//进程状态
 24         struct PCB* next;//链接指针
 25 }PCB;
 26 typedef struct
 27 {
 28     pthread_mutex_t queue_lock;//互斥锁
 29     pthread_cond_t queue_ready;//触发条件
 30     /*链表结构，线程池中所有等待任务*/
 31     CThread_worker* queue_head;
 32     /*是否销毁线程池*/
 33     int shutdown;
 34     PCB* pcbPointer;
 35     /*线程池中允许的活动线程数目*/
 36     int max_thread_num;
 37     /*当前等待队列的任务数目*/
 38     int cur_queue_size;
 39 }CThread_pool;
 40 
 41 struct CycleQueue {
 42     PCB* preThread;//当前进程的前一个进程
 43     PCB* present;//当前进程
 44 };
 45 
 46 int pool_add_worker(void* (*process) (void* arg), void* arg);
 47 void* thread_routine(void* arg);//线程要执行的函数
 48 static CThread_pool* pool = NULL;
 49 
 50 void pool_init(int max_thread_num)//初始化线程池
 51 {
 52     pool = (CThread_pool*)malloc(sizeof(CThread_pool));
 53     pthread_mutex_init(&(pool->queue_lock), NULL);//被初始化为未锁住状态
 54     pthread_cond_init(&(pool->queue_ready), NULL);
 55     pool->queue_head = NULL;
 56 pool->pcbPointer = NULL;
 57     pool->max_thread_num = max_thread_num;//3个
 58     pool->cur_queue_size = 0;
 59     pool->shutdown = 0;
 60     struct PCB *ptemp = NULL;
 61 srand(time(0));//随机种子，用于产生随机到达时间，估计运行时间
 62     for(int i=0; i<max_thread_num; ++i)
 63     {
 64         struct PCB* s = (PCB*)malloc(sizeof(PCB));
 65         s->thread_id = i+1;
 66         s->arriveTime = rand() % 5;
 67         s->runTime = rand()%5 + 1;
 68         s->status = 'N';//进程状态
 69         if(NULL == pool->pcbPointer)
 70             pool->pcbPointer = s;
 71         else
 72         {
 73 ptemp = pool->pcbPointer;
 74             while(ptemp->next)
 75             {
 76                 ptemp = ptemp->next;
 77             }
 78             ptemp->next = s;
 79         }
 80         printf("PCB%d, arrive:%d, run:%d, status:%c
",s->thread_id, s->arriveTime, s->runTime, s->status);
 81     }
 82     int i = 0;
 83     for (ptemp = pool->pcbPointer; ptemp != NULL; ptemp = ptemp->next)
 84     {
 85         pthread_create(&(ptemp->thread), NULL, thread_routine, NULL);//创建了3个线程，执行routine函数
 86 printf("thread created
");
 87     }
 88 }
 89 int pool_add_worker(void* (*process) (void* arg), void* arg)
 90 {
 91     /*构造一个新任务*/
 92     CThread_worker* newworker = (CThread_worker*)malloc(sizeof(CThread_worker));
 93     newworker->process = process;//myprocess函数
 94     newworker->arg = arg;//函数参数，为 &50
 95     newworker->next = NULL;/*别忘置空*/
 96     pthread_mutex_lock(&(pool->queue_lock));//将任务加到队列前，要上互斥锁
 97     /*将任务加入到等待队列中*/
 98     CThread_worker* member = pool->queue_head;//member指向任务队列的头
 99     if (member != NULL)//尾插法插入newworker
100     {
101         while (member->next != NULL)
102             member = member->next;
103         member->next = newworker;
104     }
105     else//队列为空
106     {
107         pool->queue_head = newworker;//直接插入newworker
108     }
109     assert(pool->queue_head != NULL);//表达式pool->queue_head != NULL必须为true
110     pool->cur_queue_size++;//当前队列数加一
111     pthread_mutex_unlock(&(pool->queue_lock));//完成添加队列的操作，解互斥锁
112     /*好了，等待队列中有任务了，唤醒一个等待线程；
113     注意如果所有线程都在忙碌，这句没有任何作用*/
114     pthread_cond_signal(&(pool->queue_ready));//触发线程，使其脱离阻塞状态
115     return 0;
116 }
117 int pool_destroy()
118 {
119     if (pool->shutdown)
120         return -1;/*防止两次调用*/
121     pool->shutdown = 1;
122     /*唤醒所有等待线程，线程池要销毁了*/
123     pthread_cond_broadcast(&(pool->queue_ready));
124     /*阻塞等待线程退出，否则就成僵尸了*/
125     int i;
126    // for (i = 0; i < pool->max_thread_num; i++)
127    //    pthread_join(pool->threadid[i], NULL);
128 
129 for(struct PCB* ptemp = pool->pcbPointer; ptemp != NULL; ptemp = ptemp->next)
130 {
131     pthread_join(ptemp->thread, NULL);    
132 }
133 
134    // free(pool->pcbPointer);
135     /*销毁等待队列*/
136     CThread_worker* head = NULL;
137     while (pool->queue_head != NULL)
138     {
139         head = pool->queue_head;
140         pool->queue_head = pool->queue_head->next;
141         free(head);
142     }
143     /*条件变量和互斥量也别忘了销毁*/
144     pthread_mutex_destroy(&(pool->queue_lock));
145     pthread_cond_destroy(&(pool->queue_ready));
146 
147     free(pool);
148     /*销毁后指针置空是个好习惯*/
149     pool = NULL;
150     return 0;
151 }
152 void* thread_routine(void* arg)//线程中要执行的函数
153 {
154     printf("starting thread 0x%x
", pthread_self());//pthread_self()获得线程自身id
155     while (1)
156     {
157         pthread_mutex_lock(&(pool->queue_lock));
158         /*如果等待队列为0并且不销毁线程池，则处于阻塞状态; 注意
159         pthread_cond_wait是一个原子操作，等待前会解锁，唤醒后会加锁*/
160         while (pool->cur_queue_size == 0 && !pool->shutdown)
161         {
162             printf("thread 0x%x is waiting
", pthread_self());
163             pthread_cond_wait(&(pool->queue_ready), &(pool->queue_lock));
164         }
165         /*线程池要销毁了*/
166         if (pool->shutdown)
167         {
168             /*遇到break,continue,return等跳转语句，千万不要忘记先解锁*/
169             pthread_mutex_unlock(&(pool->queue_lock));
170             printf("thread 0x%x will exit
", pthread_self());
171             pthread_exit(NULL);
172         }
173         printf("thread 0x%x is starting to work
", pthread_self());//线程处理中
174         /*assert是调试的好帮手*/
175         assert(pool->cur_queue_size != 0);
176         assert(pool->queue_head != NULL);
177 
178         /*等待队列长度减去1，并取出链表中的头元素*/
179         pool->cur_queue_size--;
180         CThread_worker* worker = pool->queue_head;
181         pool->queue_head = worker->next;
182         pthread_mutex_unlock(&(pool->queue_lock));
183         /*调用回调函数，执行任务*/
184         (*(worker->process)) (worker->arg);
185         free(worker);
186         worker = NULL;
187     }
188     /*这一句应该是不可达的*/
189     pthread_exit(NULL);
190 }
191 myprocess(void* arg)
192 {
193     printf("threadid is 0x%x, working on task %d
", pthread_self(), *(int*)arg);
194     sleep(1);/*休息一秒，延长任务的执行时间*/
195     return NULL;
196 }
197 int main(int argc, char** argv)
198 {
199     pool_init(5);/*线程池中最多三个活动线程*/
200     /*连续向池中投入10个任务*/
201     int* workingnum = (int*)malloc(sizeof(int) * 10);//int数组
202     int i;
203     for (i = 0; i < 10; ++i)
204     {
205       workingnum[i] = i;
206       //pool_add_worker(myprocess, &workingnum[i]);
207     }
208     /*等待所有任务完成*/
209     sleep(5);
210     /*销毁线程池*/
211     pool_destroy();
212     free(workingnum);
213     return 0;
214 }

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <semaphore.h>
  4 #include <unistd.h>
  5 #include <sys/types.h>
  6 #include <pthread.h>
  7 #define bool int
  8 #define true 1
  9 #define false 0
 10 #define thread_maxn 500//9
 11 typedef struct TCB
 12 {
 13     int thread_id;
 14     int arriveTime;
 15     int runTime;
 16     bool thrFinished;
 17     struct TCB* next;
 18 }TCB;
 19 struct tcb_queue
 20 {
 21     struct TCB *thread[thread_maxn];
 22     int r, f;
 23 };
 24 struct tcb_queue Queue;
 25 struct tcb_queue showQueue;
 26 
 27 sem_t sem[thread_maxn];//信号量，用于唤醒线程
 28 TCB* lHead = NULL;//存储线程信息
 29 TCB* nowRun;//目前正在运行的线程
 30 int nFinish = 0;
 31 int nowTime = 0;//目前时间计数
 32 TCB* tcb = NULL;
 33 
 34 void show_tcb()
 35 {
 36     printf("(show)目前队列的情况为：");
 37     while (Queue.r != Queue.f)
 38     {
 39         showQueue.f = (showQueue.f+1)%thread_maxn;
 40         Queue.r = (Queue.r + 1) % thread_maxn;
 41         showQueue.thread[showQueue.f] = Queue.thread[Queue.r];
 42         printf("%d ", Queue.thread[Queue.r]->thread_id);
 43     }
 44     while (showQueue.r != showQueue.f)
 45     {
 46         Queue.f = (Queue.f  + 1) % thread_maxn;
 47         showQueue.r = (showQueue.r + 1) % thread_maxn;
 48         Queue.thread[Queue.f] = showQueue.thread[showQueue.r];
 49     }
 50     printf("print finished
");
 51 }
 52 void create_tcb()
 53 {
 54     TCB* ptemp = tcb;
 55     srand(time(0));
 56     for (int i = 0; i < thread_maxn-1; ++i)
 57     {
 58         TCB* s = (TCB*)malloc(sizeof(TCB));
 59         s->arriveTime = rand() % 9;
 60         s->runTime = rand() % 9 + 1;
 61         s->thread_id = i;
 62         s->thrFinished = false;
 63         s->next = NULL;
 64         if (tcb == NULL)
 65         {
 66             tcb = s;
 67         }
 68         else
 69         {
 70             ptemp = tcb;
 71             while (ptemp && ptemp->next)
 72             {
 73                 ptemp = ptemp->next;
 74             }
 75             ptemp->next = s;
 76         }
 77     }
 78     printf("tcb Created
");
 79 }
 80 typedef struct
 81 {
 82     pthread_mutex_t queue_lock;//互斥锁
 83     int shutdown;//销毁
 84     pthread_t* threadid;
 85     int cur_queue_size;
 86 } CThread_pool;
 87 void* thread_routine(void* arg);//线程要执行的函数
 88 static CThread_pool* pool = NULL;
 89 void pool_init()//初始化线程池
 90 {
 91     pool = (CThread_pool*)malloc(sizeof(CThread_pool));
 92     pthread_mutex_init(&(pool->queue_lock), NULL);//被初始化为未锁住状态
 93     pool->shutdown = 0;
 94     pool->threadid = (pthread_t*)malloc(thread_maxn * sizeof(pthread_t));
 95     TCB* ptemp = tcb;
 96     while (ptemp != NULL)
 97     {
 98         pthread_create(&(pool->threadid[ptemp->thread_id]), NULL, thread_routine, ptemp);//创建线程
 99         printf("thread%d created
", ptemp->thread_id);
100         ptemp = ptemp->next;
101     }
102 }
103 void* thread_routine(void* arg)//线程中要执行的函数
104 {
105     TCB* ptemp = (TCB*)arg;
106     printf("starting ptemp->thread_id = %d
", ptemp->thread_id);
107     while (ptemp->runTime > 0)
108     {
109 sleep(1);
110         sem_wait(&sem[ptemp->thread_id]);//挂起，等待唤醒
111 printf("%dBEING WOKEN
",ptemp->thread_id);
112         pthread_mutex_lock(&(pool->queue_lock));
113         --(ptemp->runTime);
114         printf("nowTime = %d,目前轮转的线程为：%d
",nowTime, ptemp->thread_id);
115         sleep(1);
116         if (ptemp->runTime == 0)
117         {
118             ++nFinish;
119             ptemp->thrFinished = true;//该线程已完成
120             //出队列
121             Queue.r = (Queue.r + 1) % thread_maxn;//out
122         }
123         else
124         {//未完成
125             Queue.r = (Queue.r + 1) % thread_maxn;//out
126             Queue.f = (Queue.f+1)%thread_maxn;
127             Queue.thread[Queue.f] = ptemp;
128             printf("nowTime = %d,线程%d估计剩余时间为%d
",nowTime, ptemp->thread_id, ptemp->runTime);
129         }
130         pthread_mutex_unlock(&(pool->queue_lock));
131     }
132     pthread_exit(NULL);//不可达
133     return;
134 }
135 void init_sem()
136 {
137     for (int i = 0; i < thread_maxn-1; ++i)//初始化各线程信号量
138     {
139         sem_init(&sem[i], 0, 0);
140     }
141 }
142 void RoundRobin()//时间片轮转算法调度线程
143 {
144     while (1)
145     {
146         //加锁
147         pthread_mutex_lock(&(pool->queue_lock));
148         if (nFinish == thread_maxn-1)//如果所有线程都完成了
149             break;
150         printf("当前时间为%d
", nowTime);
151         TCB* ptemp = tcb;
152         while (ptemp)
153         {
154             if (ptemp->arriveTime == nowTime)
155             {
156                 //入队
157 printf("thread %d inqueue
", ptemp->thread_id);
158                 Queue.f = (Queue.f+1)%thread_maxn;
159                 Queue.thread[Queue.f] = ptemp;
160                 printf("nowTime = %d,线程%d到达，估计运行时间：%d
",nowTime, ptemp->thread_id, ptemp->runTime);
161             }
162             ptemp = ptemp->next;
163         }
164         if (Queue.r != Queue.f)
165         {
166             nowRun = Queue.thread[(Queue.r + 1) % thread_maxn];
167             printf("thread operate, nowrun = %d
",nowRun->thread_id);
168             sem_post(&sem[nowRun->thread_id]);//对应线程执行一次操作
169         }
170         //输出队列
171         printf("print queue %d and %d
",Queue.r, Queue.f);
172     show_tcb();
173         ++nowTime;
174         pthread_mutex_unlock(&(pool->queue_lock));
175         sleep(1);
176     }
177 }
178 int main()
179 {
180     showQueue.f = showQueue.r = 0;
181     Queue.r = Queue.f = 0;
182     create_tcb();
183     pool_init();//初始化线程池
184     init_sem();//初始化线程信号量
185     RoundRobin();
186     printf("rr finished
");
187     
188     TCB* ptemp = tcb;
189     while (ptemp)
190     {
191         pthread_join(pool->threadid[ptemp->thread_id], NULL);
192         printf("thread%d finished", ptemp->thread_id);
193         ptemp = ptemp->next;
194     }
195     sleep(5);
196     //销毁线程池
197     return 0;
198 }

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <semaphore.h>
  4 #include <unistd.h>
  5 #include <sys/types.h>
  6 #include <pthread.h>
  7 #define bool int
  8 #define true 1
  9 #define false 0
 10 #define thread_maxn 5//9
 11 void bubble_sort();
 12 
 13 typedef struct TCB
 14 {
 15     int thread_id;
 16     int arriveTime;
 17     int runTime;
 18     bool thrFinished;
 19     struct TCB* next;
 20 }TCB;
 21 struct tcb_queue
 22 {
 23     struct TCB *thread[thread_maxn];
 24     int r, f;
 25 };
 26 struct tcb_queue Queue;
 27 struct tcb_queue showQueue;
 28 
 29 sem_t sem[thread_maxn];//信号量，用于唤醒线程
 30 TCB* lHead = NULL;//存储线程信息
 31 TCB* nowRun;//目前正在运行的线程
 32 int nFinish = 0;
 33 int nowTime = 0;//目前时间计数
 34 TCB* tcb = NULL;
 35 
 36 void show_rr()
 37 {
 38     printf("(show)目前队列的情况为：");
 39     while (Queue.r != Queue.f)
 40     {
 41         showQueue.f = (showQueue.f+1)%thread_maxn;
 42         Queue.r = (Queue.r + 1) % thread_maxn;
 43         showQueue.thread[showQueue.f] = Queue.thread[Queue.r];
 44         printf("%d ", Queue.thread[Queue.r]->thread_id);
 45     }
 46     while (showQueue.r != showQueue.f)
 47     {
 48         Queue.f = (Queue.f  + 1) % thread_maxn;
 49         showQueue.r = (showQueue.r + 1) % thread_maxn;
 50         Queue.thread[Queue.f] = showQueue.thread[showQueue.r];
 51     }
 52     printf("print finished
");
 53 }
 54 void show_tcb()
 55 {
 56     printf("show_tcb");
 57     TCB* ptemp = tcb;
 58 while(ptemp)
 59 {
 60     printf("thread%d: arrive:%d, left:%d
",ptemp->thread_id, ptemp->arriveTime, ptemp->runTime);
 61 ptemp = ptemp->next;
 62 }
 63     printf("show_tcb finished
");
 64 }
 65 void create_tcb()
 66 {
 67     TCB* ptemp = tcb;
 68     srand(time(0));
 69     for (int i = 0; i < thread_maxn-1; ++i)
 70     {
 71         TCB* s = (TCB*)malloc(sizeof(TCB));
 72         s->arriveTime = rand() % 9;
 73         s->runTime = rand() % 9 + 1;
 74         s->thread_id = i;
 75         s->thrFinished = false;
 76         s->next = NULL;
 77         if (tcb == NULL)
 78         {
 79             tcb = s;
 80         }
 81         else
 82         {
 83             ptemp = tcb;
 84             while (ptemp && ptemp->next)
 85             {
 86                 ptemp = ptemp->next;
 87             }
 88             ptemp->next = s;
 89         }
 90     }
 91     printf("tcb Created
");
 92 }
 93 typedef struct
 94 {
 95     pthread_mutex_t queue_lock;//互斥锁
 96     int shutdown;//销毁
 97     pthread_t* threadid;
 98     int cur_queue_size;
 99 } CThread_pool;
100 void* thread_routine(void* arg);//线程要执行的函数
101 static CThread_pool* pool = NULL;
102 void pool_init()//初始化线程池
103 {
104     pool = (CThread_pool*)malloc(sizeof(CThread_pool));
105     pthread_mutex_init(&(pool->queue_lock), NULL);//被初始化为未锁住状态
106     pool->shutdown = 0;
107     pool->threadid = (pthread_t*)malloc(thread_maxn * sizeof(pthread_t));
108     TCB* ptemp = tcb;
109     while (ptemp != NULL)
110     {
111         pthread_create(&(pool->threadid[ptemp->thread_id]), NULL, thread_routine, ptemp);//创建线程
112         printf("thread%d created
", ptemp->thread_id);
113         ptemp = ptemp->next;
114     }
115 }
116 void* thread_routine(void* arg)//线程中要执行的函数
117 {
118     TCB* ptemp = (TCB*)arg;
119     printf("starting ptemp->thread_id = %d
", ptemp->thread_id);
120     while (ptemp->runTime > 0)
121     {
122 sleep(1);
123         sem_wait(&sem[ptemp->thread_id]);//挂起，等待唤醒
124 printf("%dBEING WOKEN
",ptemp->thread_id);
125         pthread_mutex_lock(&(pool->queue_lock));
126         //--(ptemp->runTime);
127 ptemp->runTime -= 2;
128         printf("nowTime = %d,目前轮转的线程为：%d
",nowTime, ptemp->thread_id);
129         sleep(1);
130         if (ptemp->runTime <= 0)
131         {
132             ++nFinish;
133             ptemp->thrFinished = true;//该线程已完成
134             //出队列
135             Queue.r = (Queue.r + 1) % thread_maxn;//out
136         }
137         else
138         {//未完成
139             Queue.r = (Queue.r + 1) % thread_maxn;//out
140             Queue.f = (Queue.f+1)%thread_maxn;
141             Queue.thread[Queue.f] = ptemp;
142             printf("nowTime = %d,线程%d估计剩余时间为%d
",nowTime, ptemp->thread_id, ptemp->runTime);
143         }
144         pthread_mutex_unlock(&(pool->queue_lock));
145 sleep(1);
146     }
147     pthread_exit(NULL);//不可达
148     return;
149 }
150 void init_sem()
151 {
152     for (int i = 0; i < thread_maxn-1; ++i)//初始化各线程信号量
153     {
154         sem_init(&sem[i], 0, 0);
155     }
156 }
157 void RoundRobin()//时间片轮转算法调度线程
158 {
159  TCB* ptemp = tcb;
160     while (1)
161     {
162         //加锁
163         pthread_mutex_lock(&(pool->queue_lock));
164         if (nFinish == thread_maxn-1)//如果所有线程都完成了
165             break;
166        // printf("当前时间为%d
", nowTime);
167        // TCB* ptemp = tcb;
168        // while (ptemp)
169 while(ptemp && ptemp->arriveTime == nowTime)
170         {
171             //if (ptemp->arriveTime == nowTime)
172             {
173                 //入队
174 printf("thread %d inqueue
", ptemp->thread_id);
175                 Queue.f = (Queue.f+1)%thread_maxn;
176                 Queue.thread[Queue.f] = ptemp;
177                 printf("nowTime = %d,线程%d到达，估计运行时间：%d
",nowTime, ptemp->thread_id, ptemp->runTime);
178             }
179             ptemp = ptemp->next;
180         }
181         if (Queue.r != Queue.f)
182         {
183             nowRun = Queue.thread[(Queue.r + 1) % thread_maxn];
184             printf("thread operate, nowrun = %d
",nowRun->thread_id);
185 sleep(1);         
186    sem_post(&sem[nowRun->thread_id]);//对应线程执行一次操作
187 sleep(1);
188         }
189         //输出队列
190         printf("print queue %d and %d
",Queue.r, Queue.f);
191     show_rr();
192         ++nowTime;
193         pthread_mutex_unlock(&(pool->queue_lock));
194         sleep(1);
195     }
196 }
197 int pool_destroy()
198 {
199     if (pool->shutdown)
200         return -1;
201     pool->shutdown = 1;
202     TCB* ptemp = tcb;
203     ptemp = tcb;
204     while (ptemp)
205     {
206         pthread_join(pool->threadid[ptemp->thread_id], NULL);
207         printf("thread%d finished
", ptemp->thread_id);
208         ptemp = ptemp->next;
209     }
210     free(ptemp);
211     free(pool->threadid);
212     printf("pool is freeed
");
213 
214     pthread_mutex_destroy(&(pool->queue_lock));
215     free(pool);
216     /*销毁后指针置空是个好习惯*/
217     pool = NULL;
218 }
219 int main()
220 {
221     showQueue.f = showQueue.r = 0;
222     Queue.r = Queue.f = 0;
223     create_tcb();
224 show_tcb();
225     bubble_sort();//tcb sort
226     pool_init();//初始化线程池
227     init_sem();//初始化线程信号量
228     RoundRobin();
229     printf("rr finished
");
230     
231     sleep(5);
232 
233 pool_destroy();
234     //销毁线程池
235     return 0;
236 }
237 
238 void bubble_sort()//tcb
239 {
240     TCB* ptemp = NULL;
241     for (int i = 0; i < thread_maxn; ++i)
242     {
243         ptemp = tcb;
244         while (ptemp && ptemp->next)
245         {
246             if (ptemp->arriveTime > ptemp->next->arriveTime)
247             {
248                 TCB* p_next = ptemp->next->next;
249                 TCB* p_pre = ptemp;
250                 TCB* p_pre_pre = tcb;
251                 if (p_pre_pre == p_pre)
252                 {
253                     p_pre_pre = NULL;
254                 }
255                 else
256                 {
257                     while (p_pre_pre != NULL && p_pre_pre->next != p_pre)
258                     {
259                         p_pre_pre = p_pre_pre->next;
260                     }
261                 }
262                 ptemp = ptemp->next;
263                 ptemp->next = p_pre;
264                 p_pre->next = p_next;
265                 if (p_pre_pre != NULL)
266                 {
267                     p_pre_pre->next = ptemp;
268                 }
269                 else
270                 {
271                       tcb = ptemp;
272                 }
273             }
274                 ptemp = ptemp->next;
275         }
276     }
277 }

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <semaphore.h>
  4 #include <unistd.h>
  5 #include <sys/types.h>
  6 #include <pthread.h>
  7 #define bool int
  8 #define true 1
  9 #define false 0
 10 #define THREAD_MAXN 5//线程数
 11 #define RUNTIME_SUB 1//每次运行线程减去的运行时间
 12 //-----结构体定义
 13 typedef struct TCB//存储线程信息
 14 {
 15     int thread_id;//线程编号
 16     int arriveTime;//线程到达时间
 17     int runTime;//持续时间
 18     int finishTime;//完成时间
 19     int wholeTime;//周转时间
 20     double weightWholeTime;//带权周转时间
 21     bool Finished;//线程是否完成
 22     struct TCB* next;//使用链式存储方式
 23 }TCB;
 24 struct tcb_queue//TCB队列定义
 25 {
 26     struct TCB* tcbQueue[THREAD_MAXN];//TCB指针数组
 27     int r,f;
 28 };
 29 struct thread_pool//线程池结构体
 30 {
 31     pthread_mutex_t tcb_lock;//互斥锁
 32     int fDestroyed;//线程池是否被销毁
 33     pthread_t *threadid;//存储线程标识符指针
 34     TCB *nowRunThread;//指向当前正在运行的线程 
 35     int nExist;//现存现存
 36     int nFinish;//当前已完成的线程数
 37     sem_t sem[THREAD_MAXN];//用于控制线程的信号量
 38     struct tcb_queue pool->rrQueue;//轮转队列
 39     struct tcb_queue pool->showQueue;//用于辅助打印的队列
 40     TCB *tcb;//存储TCB
 41 };
 42 //-----全局变量定义
 43 thread_pool POOL;
 44 static thread_pool *pool = &POOL;//全局变量pool，指向线程池
 45 int nowTime;//当前已走过的时间
 46 //-----函数声明
 47 void bubble_sort();//给TCB排序
 48 void show_rr();//打印轮转队列
 49 void show_tcb();//打印所有线程的信息
 50 void pool_init();//初始化线程池
 51 void thread_run_func(void* param);//线程里运行的函数
 52 void round_robin();//时间片轮转算法的调度函数
 53 int pool_destroy();//销毁线程池
 54 //main
 55 int main()
 56 {
 57     pool_init();
 58     printf("TCB初始化完成！
");
 59     printf("打印初始TCB：
");
 60     show_tcb();
 61     printf("TCB按到达时间排序后：
");
 62     bubble_sort();
 63     show_tcb();
 64     printf("所有线程已完成
");
 65     sleep(5);//等待所有线程完成
 66     pool_destroy();
 67     return 0;
 68 }
 69 //函数定义
 70 void bubble_sort()//给TCB排序,按arriveTime升序排列
 71 {
 72 TCB* ptemp = NULL;
 73 for(int i=0; i<THREAD_MAXN; ++i)
 74 {
 75     ptemp = pool->tcb;
 76     while(ptemp && ptemp->next)
 77     {
 78         if(ptemp->arriveTime > ptemp->next->arriveTime)
 79         {//交换两个节点
 80             TCB *p_next = ptemp->next->next;
 81             TCB *p_pre = ptemp;
 82             TCB *p_pre_pre = pool->tcb;
 83             if(p_pre_pre == p_pre)
 84             {
 85                 p_pre_pre = NULL;
 86             }
 87             else
 88             {
 89                 while(p_pre_pre && p_pre_pre->next != p_pre)
 90                 {
 91                     p_pre_pre = p_pre_pre->next;
 92                 }
 93             }
 94             ptemp = ptemp->next;
 95             ptemp->next = p_pre;
 96             p_pre->next = p_next;
 97             if(p_pre_pre)
 98             {
 99                 p_pre_pre->next = ptemp;
100             }
101             else
102             {
103                 pool->tcb = ptemp;
104             } 
105         }
106         ptemp = ptemp->next;
107     }    
108 }
109 }
110 void show_rr()//打印轮转队列
111 {
112 printf("目前在轮转队列中线程为：
");
113 while(pool->rrQueue.r != pool->rrQueue.f)
114 {
115     pool->showQueue.f = (pool->showQueue.f + 1) % THREAD_MAXN;
116     pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
117     pool->showQueue.tcbQueue[pool->showQueue.f] = pool->rrQueue.tcbQueue[pool->rrQueue.r];
118     printf("%d ",pool->rrQueue.tcbQueue[pool->rrQueue.r]->thread_id);
119 }
120 while(pool->showQueue.r != pool->showQueue.f)//将队列放回
121 {
122     pool->rrQueue.f = (pool->rrQueue.f + 1) % THREAD_MAXN;
123     pool->showQueue.r = (pool->showQueue.r + 1) % THREAD_MAXN;
124     pool->rrQueue.tcbQueue[pool->rrQueue.f] = pool->showQueue.tcbQueue[pool->showQueue.r];
125 }
126 printf("
");
127 }
128 void show_tcb()//打印所有线程的信息
129 {
130 TCB *ptemp = pool->tcb;
131 printf("打印所有线程的信息：
");
132 while(ptemp)
133 {
134     printf("线程%d：到达时间：%d，剩余时间：%d
", ptemp->thread_id, ptemp->arriveTime, ptemp->runTime);
135     ptemp = ptemp->next;
136 }
137 printf("
");
138 }
139 void pool_init()//初始化线程池
140 {
141 pool = (thread_pool*)malloc(sizeof(thread_pool));
142 pool->pthread_mutex_init(&(pool->tcb_lock));//初始为未锁住状态
143 pool->fDestroyed = 0;//线程池是否被销毁
144 pool->nowRunThread = NULL;//指向当前正在运行的线程 
145 pool->nExist = 0;//现存线程
146 pool->nFinish = 0;//当前已完成的线程数
147 pool->rrQueue.r = pool->rrQueue.q = 0;//轮转队列
148 pool->showQueue.r = pool->showQueue.r = 0;//用于辅助打印的队列
149 //创建并初始化TCB
150 TCB* ptemp = pool->tcb;
151 srand(time(0));
152 for(int i=0; i<THREAD_MAXN-1; ++i)
153 {
154     TCB* s = (*TCB)malloc(sizeof(TCB));
155     s->arriveTime = rand()%9;
156     s->runTime = rand()%9+1;
157     s->thread_id = i;//编号令为0
158     s->Finished = fsemalse;
159     s->next = NULL;
160     //尾插入
161     if(pool->tcb == NULL)//第一个节点
162         tcb = s;
163     else
164     {
165         ptemp = pool->tcb;
166         while(ptemp && ptemp->next)
167         {
168             ptemp = ptemp->next;
169         }
170         ptemp->next = s;
171     }
172 }
173 //初始化信号量sem
174 ptemp = pool->tcb;
175 while(ptemp)
176 {
177     sem_init(&(ptemp->thread_id), 0, 0);
178     ptemp = ptemp->next;
179 }
180 //创建线程
181 ptemp = pool->tcb;
182 threadid = (pthread_t*)malloc(sizeof(pthread_t) * THREAD_MAXN);
183 while(ptemp)
184 {
185     //把ptemp作为参数传入thread_run_func()
186     int t;
187     t = pthread_create(&(pool->threadid[ptemp->thread_id]), 
188                             NULL, thread_run_func, ptemp);
189     if(!t)//线程创建成功
190     {
191         printf("线程%d创建成功!
", ptemp->thread_id);
192     }
193     else
194     {
195         printf("线程创建失败!
");
196     }
197     ptemp = ptemp->next;
198 }
199 printf("线程池pool初始化完成！
");
200 }
201 void thread_run_func(void *param)//线程里运行的函数
202 {
203 TCB *ptemp = (*TCB)param;
204 // prtinf("线程%d开始了", ptemp->thread_id);
205 while(ptemp->runTime > 0)
206 {
207     printf("线程%d正在等待……
");
208     sleep(1);
209     sem_wait(&(pool->sem[ptemp->thread_id]));//唤醒
210     printf("线程%d已被唤醒！
");
211     pthread_mutex_lock(&(pool->tcb_lock));//上互斥锁
212     ptemp->runTime -= RUNTIME_SUB;
213     printf("当前时间为：%d，轮转的线程为线程%d，该线程剩余时间：%d->%d
",
214             nowTime, ptemp->thread_id, ptemp->runTime+RUNTIME_SUB, ptemp->runTime<0?0:ptemp->runTime);
215     sleep(1);
216     if(ptemp->runTime <= 0)//线程已经完成
217     {
218         ++pool->nFinish;
219         ptemp->Finished = true;
220         //出队
221         pool->rrQueue.r = (pool->rrQueue.r+1)%THREAD_MAXN;
222     }
223     else
224     {//还未完成
225         //出队
226         pool->rrQueue.r = (pool->rrQueue.r+1)%THREAD_MAXN;
227         //入队
228         pool->rrQueue.f = (pool->rrQueue.f + 1) % THREAD_MAXN;
229         pool->rrQueue.thread[pool->rrQueue.f] = ptemp;
230     }
231     pthread_mutex_unlock(&(pool->tcb_lock));
232     sleep(1);
233 }
234 pthread_exit(NULL);
235 }
236 void round_robin()//时间片轮转算法的调度函数
237 {
238     TCB *ptemp = pool->tcb;
239     while(1)
240     {
241         sleep(1);
242         pthread_mutex_lock(&(pool->tcb_lock));
243         if(pool->nFinished == THREAD_MAXN-1)//所有线程完成
244             break;
245         while(ptemp && ptemp->arriveTime == nowTime)
246         {
247             printf("当前时间为：%d，线程%d进入轮转队列，剩余运行时间：%d
", 
248                 nowTime, ptemp->thread_id, ptemp->runTime);
249             pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
250             pool->rrQueue.tcbQueue[pool->rrQueue.f] = ptemp;
251             ptemp = ptemp->next;
252         }
253         if(pool->rrQueue.r != pool->rrQueue.f)
254         {
255             pool->nowRunThread = pool->rrQueue.tcbQueue[(pool->rrQueue+1)%THREAD_MAXN];
256             printf("准备唤醒线程线程%d
",pool->nowRunThread->thread_id);
257             sleep(1);
258             sem_post(&(pool->sem[pool->nowRunThread->thread_id]));
259         }
260         show_rr();
261         ++nowTime;
262         pthread_mutex_unlock(&(pool->tcb_lock));
263         sleep(1);
264     }
265 }
266 int pool_destroy()//销毁线程池
267 {
268     if(pool->fDestroyed)//防止重复销毁
269         return -1;
270     pool->fDestroyed = 1;
271     TCB* ptemp = pool->tcb;
272     while(ptemp)
273     {
274         pthread_join(pool->threadid[ptemp->thread_id], NULL);
275         printf("线程%d已结束
",ptemp->thread_id);
276         ptemp = ptemp->next;
277     }
278     free(ptemp);
279     free(pool->threadid);
280     pthread_mutex_destroy(&(pool->tcb_lock));
281     free(pool);
282     pool = NULL;
283     printf("线程池pool已被销毁！
");
284 }

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <semaphore.h>
  4 #include <unistd.h>
  5 #include <time.h>
  6 #include <sys/types.h>
  7 #include <pthread.h>
  8 #define bool int
  9 #define true 1
 10 #define false 0
 11 #define THREAD_MAXN 5//线程数
 12 #define RUNTIME_SUB 1//每次运行线程减去的运行时间
 13 //-----结构体定义
 14 typedef struct TCB//存储线程信息
 15 {
 16     int thread_id;//线程编号
 17     int arriveTime;//线程到达时间
 18     int runTime;//持续时间
 19     int finishTime;//完成时间
 20     int wholeTime;//周转时间
 21     double weightWholeTime;//带权周转时间
 22     bool Finished;//线程是否完成
 23     struct TCB* next;//使用链式存储方式
 24 }TCB;
 25 struct tcb_queue//TCB队列定义
 26 {
 27     struct TCB* tcbQueue[THREAD_MAXN];//TCB指针数组
 28     int r,f;
 29 };
 30 struct thread_pool//线程池结构体
 31 {
 32     pthread_mutex_t tcb_lock;//互斥锁
 33     int fDestroyed;//线程池是否被销毁
 34     pthread_t *threadid;//存储线程标识符指针
 35     struct TCB *nowRunThread;//指向当前正在运行的线程
 36     int nExist;//现存现存
 37     int nFinish;//当前已完成的线程数
 38     sem_t sem[THREAD_MAXN];//用于控制线程的信号量
 39     struct tcb_queue rrQueue;//轮转队列
 40     struct tcb_queue showQueue;//用于辅助打印的队列
 41     struct TCB *tcb;//存储TCB
 42 };
 43 //-----全局变量定义
 44 static struct thread_pool *pool = NULL;//全局变量pool，指向线程池
 45 int nowTime;//当前已走过的时间
 46 //-----函数声明
 47 void bubble_sort();//给TCB排序
 48 void show_rr();//打印轮转队列
 49 void show_tcb();//打印所有线程的信息
 50 void pool_init();//初始化线程池
 51 void thread_run_func(void* param);//线程里运行的函数
 52 void round_robin();//时间片轮转算法的调度函数
 53 int pool_destroy();//销毁线程池
 54 //main
 55 int main()
 56 {
 57     pool_init();
 58     printf("打印初始TCB：
");
 59     show_tcb();
 60     printf("TCB按到达时间排序后：
");
 61     bubble_sort();
 62     show_tcb();
 63     round_robin();
 64     sleep(5);//等待所有线程完成
 65     pool_destroy();
 66     return 0;
 67 }
 68 //函数定义
 69 void bubble_sort()//给TCB排序,按arriveTime升序排列
 70 {
 71 TCB* ptemp = NULL;
 72 for(int i=0; i<THREAD_MAXN; ++i)
 73 {
 74     ptemp = pool->tcb;
 75     while(ptemp && ptemp->next)
 76     {
 77         if(ptemp->arriveTime > ptemp->next->arriveTime)
 78         {//交换两个节点
 79             TCB *p_next = ptemp->next->next;
 80             TCB *p_pre = ptemp;
 81             TCB *p_pre_pre = pool->tcb;
 82             if(p_pre_pre == p_pre)
 83             {
 84                 p_pre_pre = NULL;
 85             }
 86             else
 87             {
 88                 while(p_pre_pre && p_pre_pre->next != p_pre)
 89                 {
 90                     p_pre_pre = p_pre_pre->next;
 91                 }
 92             }
 93             ptemp = ptemp->next;
 94             ptemp->next = p_pre;
 95             p_pre->next = p_next;
 96             if(p_pre_pre)
 97             {
 98                 p_pre_pre->next = ptemp;
 99             }
100             else
101             {
102                 pool->tcb = ptemp;
103             }
104         }
105         ptemp = ptemp->next;
106     }
107 }
108 }
109 void show_rr()//打印轮转队列
110 {
111 printf("当前时间为：%d
",nowTime);
112 if(pool->rrQueue.r == pool->rrQueue.f)
113 {
114     printf("目前还没有线程到达
");
115 }
116 else
117 {
118     printf("目前轮转队列为：
");
119 }
120 while(pool->rrQueue.r != pool->rrQueue.f)
121 {
122     pool->showQueue.f = (pool->showQueue.f + 1) % THREAD_MAXN;
123     pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
124     pool->showQueue.tcbQueue[pool->showQueue.f] = pool->rrQueue.tcbQueue[pool->rrQueue.r];
125     printf("%d ",pool->rrQueue.tcbQueue[pool->rrQueue.r]->thread_id);
126 }
127 while(pool->showQueue.r != pool->showQueue.f)//将队列放回
128 {
129     pool->rrQueue.f = (pool->rrQueue.f + 1) % THREAD_MAXN;
130     pool->showQueue.r = (pool->showQueue.r + 1) % THREAD_MAXN;
131     pool->rrQueue.tcbQueue[pool->rrQueue.f] = pool->showQueue.tcbQueue[pool->showQueue.r];
132 }
133 printf("

");
134 }
135 void show_tcb()//打印所有线程的信息
136 {
137 TCB *ptemp = pool->tcb;
138 printf("打印所有线程的信息：
");
139 while(ptemp)
140 {
141     printf("线程%d：到达时间：%d，剩余时间：%d
", ptemp->thread_id, ptemp->arriveTime, ptemp->runTime);
142     ptemp = ptemp->next;
143 }
144 printf("
");
145 }
146 void pool_init()//初始化线程池
147 {
148 pool = (struct thread_pool*)malloc(sizeof(struct thread_pool));
149 pthread_mutex_init(&(pool->tcb_lock), NULL);//初始为未锁住状态
150 pool->fDestroyed = 0;//线程池是否被销毁
151 pool->nowRunThread = NULL;//指向当前正在运行的线程
152 pool->nExist = 0;//现存线程
153 pool->nFinish = 0;//当前已完成的线程数
154 pool->rrQueue.r = pool->rrQueue.f = 0;//轮转队列
155 pool->showQueue.r = pool->showQueue.r = 0;//用于辅助打印的队列
156 pool->tcb = NULL;
157 //创建并初始化TCB
158 TCB* ptemp = pool->tcb;
159 srand(time(0));
160 for(int i=0; i<THREAD_MAXN-1; ++i)
161 {
162     TCB* s = (TCB*)malloc(sizeof(TCB));
163     s->arriveTime = rand()%9;
164     s->runTime = rand()%9+1;
165     s->thread_id = i;//编号令为0
166     s->Finished = false;
167     s->next = NULL;
168     //尾插入
169     if(!pool->tcb)//第一个节点
170     {
171         pool->tcb = s;
172     }
173     else
174     {
175         ptemp = pool->tcb;
176         while(ptemp && ptemp->next)
177         {
178             ptemp = ptemp->next;
179         }
180         ptemp->next = s;
181     }
182 }
183 //初始化信号量sem
184 ptemp = pool->tcb;
185 int i=0;
186 while(ptemp != NULL)
187 {
188     int i = ptemp->thread_id;
189     sem_init(&(pool->sem[i]), 0, 0);
190     ptemp = ptemp->next;
191 }
192 //创建线程
193 ptemp = pool->tcb;
194 pool->threadid = (pthread_t*)malloc(sizeof(pthread_t) * THREAD_MAXN);
195 while(ptemp != NULL)
196 {
197     //把ptemp作为参数传入thread_run_func()
198     int t;
199     t = pthread_create(&(pool->threadid[ptemp->thread_id]), 
200                             NULL, thread_run_func, ptemp);
201     if(!t)//线程创建成功
202     {
203         printf("线程%d创建成功!
", ptemp->thread_id);
204     }
205     else
206     {
207         printf("线程创建失败!
");
208     }
209     ptemp = ptemp->next;
210 }
211 printf("线程池pool初始化完成！
");
212 }
213 void thread_run_func(void *param)//线程里运行的函数
214 {
215 TCB *ptemp = (TCB*)param;
216 // prtinf("线程%d开始了", ptemp->thread_id);
217 while(ptemp->runTime > 0)
218 {
219     printf("线程%d正在等待……
", ptemp->thread_id);
220     sleep(1);
221     sem_wait(&(pool->sem[ptemp->thread_id]));//唤醒
222     printf("线程%d已被唤醒！
",ptemp->thread_id);
223     pthread_mutex_lock(&(pool->tcb_lock));//上互斥锁
224     ptemp->runTime -= RUNTIME_SUB;
225     printf("当前时间为：%d，轮转的线程为线程%d，该线程剩余时间：%d->%d
",
226             nowTime, ptemp->thread_id, ptemp->runTime+RUNTIME_SUB, ptemp->runTime<0?0:ptemp->runTime);
227     sleep(1);
228     if(ptemp->runTime <= 0)//线程已经完成
229     {
230         ++pool->nFinish;
231         ptemp->Finished = true;
232         //出队
233         pool->rrQueue.r = (pool->rrQueue.r+1)%THREAD_MAXN;
234     }
235     else
236     {//还未完成
237         //出队
238         pool->rrQueue.r = (pool->rrQueue.r+1)%THREAD_MAXN;
239         //入队
240         pool->rrQueue.f = (pool->rrQueue.f + 1) % THREAD_MAXN;
241         pool->rrQueue.tcbQueue[pool->rrQueue.f] = ptemp;
242     }
243     pthread_mutex_unlock(&(pool->tcb_lock));
244     sleep(1);
245 }
246 pthread_exit(NULL);
247 }
248 void round_robin()//时间片轮转算法的调度函数
249 {
250     TCB *ptemp = pool->tcb;
251     while(1)
252     {
253         sleep(1);
254         pthread_mutex_lock(&(pool->tcb_lock));
255         if(pool->nFinish == THREAD_MAXN-1)//所有线程完成
256             break;
257         while(ptemp && ptemp->arriveTime == nowTime)
258         {
259             printf("当前时间为：%d，线程%d进入轮转队列，运行时间：%d
", 
260             nowTime, ptemp->thread_id, ptemp->runTime);
261             pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
262             pool->rrQueue.tcbQueue[pool->rrQueue.f] = ptemp;
263             ptemp = ptemp->next;
264         }
265         if(pool->rrQueue.r != pool->rrQueue.f)
266         {
267             pool->nowRunThread = pool->rrQueue.tcbQueue[(pool->rrQueue.r+1)%THREAD_MAXN];
268             printf("准备唤醒线程%d
",pool->nowRunThread->thread_id);
269             sleep(1);
270             sem_post(&(pool->sem[pool->nowRunThread->thread_id]));
271         }
272         show_rr();
273         ++nowTime;
274         pthread_mutex_unlock(&(pool->tcb_lock));
275         sleep(1);
276     }
277 }
278 int pool_destroy()//销毁线程池
279 {
280     if(pool->fDestroyed)//防止重复销毁
281         return -1;
282     pool->fDestroyed = 1;
283     TCB* ptemp = pool->tcb;
284     while(ptemp)
285     {
286         pthread_join(pool->threadid[ptemp->thread_id], NULL);
287         printf("线程%d已结束
",ptemp->thread_id);
288         ptemp = ptemp->next;
289     }
290     free(ptemp);
291     free(pool->threadid);
292     pthread_mutex_destroy(&(pool->tcb_lock));
293     free(pool);
294     pool = NULL;
295     printf("线程池pool已被销毁！
");
296 }

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <string.h>
  4 #include <semaphore.h>
  5 #include <unistd.h>
  6 #include <time.h>
  7 #include <sys/types.h>
  8 #include <pthread.h>
  9 #define bool int
 10 #define true 1
 11 #define false 0
 12 #define THREAD_MAXN 3//线程数
 13 #define RUNTIME_SUB 1//每次运行线程减去的运行时间
 14 #define INIT_FREE_BLOCK_NUM 8
 15 #define INIT_FREE_BLOCK_SIZE 10
 16 #define STU_NUM 50
 17 //-----结构体定义
 18 typedef struct TCB//存储线程信息
 19 {
 20     int thread_id;//线程编号
 21     int arriveTime;//线程到达时间
 22     int runTime;//持续时间
 23     int finishTime;//完成时间
 24     int wholeTime;//周转时间
 25     double weightWholeTime;//带权周转时间
 26     bool Finished;//线程是否完成
 27     struct TCB* next;//使用链式存储方式
 28 }TCB;
 29 struct tcb_queue//TCB队列定义
 30 {
 31     struct TCB* tcbQueue[THREAD_MAXN];//TCB指针数组
 32     int r,f;
 33 };
 34 struct thread_pool//线程池结构体
 35 {
 36     pthread_mutex_t tcb_lock;//互斥锁
 37     int fDestroyed;//线程池是否被销毁
 38     pthread_t *threadid;//存储线程标识符指针
 39     struct TCB *nowRunThread;//指向当前正在运行的线程     
 40     int nFinish;//完成线程数
 41     sem_t sem[THREAD_MAXN];//用于控制线程的信号量
 42     struct tcb_queue rrQueue;//轮转队列
 43     struct tcb_queue showQueue;//用于辅助打印的队列
 44     struct TCB *tcb;//存储TCB
 45 };
 46 struct free_block
 47 {
 48     int start;
 49     int size;
 50     struct free_block *next;
 51 };
 52 struct busy_block
 53 {
 54     int id;//编号
 55     int start;
 56     int size;
 57     char *data;//根据需要动态分配
 58     struct busy_blocl *next;
 59 };
 60 struct student
 61 {
 62     char number[8];
 63     char name[20];
 64     int name_size;
 65     int number_stored;
 66     int name_stored;
 67 };
 68 //-----全局变量定义
 69 static struct thread_pool *pool = NULL;//全局变量pool，指向线程池
 70 int nowTime;//当前已走过的时间
 71 int busy_id = -1;
 72 int nFree = 0;
 73 int nBusy = 0;
 74 int stuCnt = 0;
 75 struct free_block *free_queue = NULL;
 76 struct busy_block *busy_queue = NULL;
 77 struct student student_info[STU_NUM];
 78 //-----函数声明
 79 void bubble_sort();//给TCB排序
 80 void show_rr();//打印轮转队列
 81 void show_tcb();//打印所有线程的信息
 82 void pool_init();//初始化线程池
 83 void thread_run_func(void* param);//线程里运行的函数
 84 void round_robin();//时间片轮转算法的调度函数
 85 int pool_destroy();//销毁线程池
 86 void init_free();
 87 struct free_block* create_free(int start, int size, struct free_block *next);
 88 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data);
 89 struct free_block * merge_free(struct free_block *f1, struct free_block *f2);
 90 void init_student();
 91 void insert_busy(struct busy_block *pBusy);
 92 void insert_free(struct free_block *pFree);
 93 void delete_free(struct free_block *pFree);
 94 void delete_busy();
 95 void show_free();
 96 void show_busy();
 97 void FF_bubble();
 98 void BF_bubble();
 99 void WF_bubble();
100 //main
101 int main()
102 {
103     init_free();
104     printf("---------------------------------1
");
105     init_student();
106     printf("---------------------------------2
");
107     pool_init();
108     printf("---------------------------------3
");
109     printf("打印初始TCB：
");
110     show_tcb();
111     printf("TCB按到达时间排序后：
");
112     bubble_sort();
113     show_tcb();
114     printf("使用时间片轮转算法调度:
");
115     round_robin();
116     sleep(5);//等待所有线程完成
117     pool_destroy();
118     return 0;
119 }
120 //函数定义
121 void bubble_sort()//给TCB排序,按arriveTime升序排列
122 {
123 TCB* ptemp = NULL;
124 for(int i=0; i<THREAD_MAXN; ++i)
125 {
126     ptemp = pool->tcb;
127     while(ptemp && ptemp->next)
128     {
129         if(ptemp->arriveTime > ptemp->next->arriveTime)
130         {//交换两个节点
131             TCB *p_next = ptemp->next->next;
132             TCB *p_pre = ptemp;
133             TCB *p_pre_pre = pool->tcb;
134             if(p_pre_pre == p_pre)
135             {
136                 p_pre_pre = NULL;
137             }
138             else
139             {
140                 while(p_pre_pre && p_pre_pre->next != p_pre)
141                 {
142                     p_pre_pre = p_pre_pre->next;
143                 }
144             }
145             ptemp = ptemp->next;
146             ptemp->next = p_pre;
147             p_pre->next = p_next;
148             if(p_pre_pre)
149             {
150                 p_pre_pre->next = ptemp;
151             }
152             else
153             {
154                 pool->tcb = ptemp;
155             } 
156         }
157         ptemp = ptemp->next;
158     }    
159 }
160 }
161 void show_rr()//打印轮转队列
162 {
163 printf("当前时间为：%d
",nowTime);
164 if(pool->rrQueue.f == pool->rrQueue.r)
165 {
166     printf("目前还没有线程到达
");
167 }
168 else
169 {
170     printf("目前轮转队列为：
");
171 }
172 while(pool->rrQueue.f != pool->rrQueue.r)
173 {
174     pool->showQueue.f = (pool->showQueue.f + 1) % THREAD_MAXN;
175     pool->rrQueue.f = (pool->rrQueue.f + 1) % THREAD_MAXN;
176     pool->showQueue.tcbQueue[pool->showQueue.f] = pool->rrQueue.tcbQueue[pool->rrQueue.f];
177     printf("%d ",pool->rrQueue.tcbQueue[pool->rrQueue.f]->thread_id);
178 }
179 while(pool->showQueue.r != pool->showQueue.f)//将队列放回
180 {
181     pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
182     pool->showQueue.r = (pool->showQueue.r + 1) % THREAD_MAXN;
183     pool->rrQueue.tcbQueue[pool->rrQueue.r] = pool->showQueue.tcbQueue[pool->showQueue.r];
184 }
185 printf("

");
186 }
187 void show_tcb()//打印所有线程的信息
188 {
189 TCB *ptemp = pool->tcb;
190 printf("打印所有线程的信息：
");
191 while(ptemp)
192 {
193     printf("线程%d：到达时间：%d，剩余时间：%d
", ptemp->thread_id, ptemp->arriveTime, ptemp->runTime);
194     ptemp = ptemp->next;
195 }
196 printf("
");
197 }
198 void pool_init()//初始化线程池
199 {
200 pool = (struct thread_pool*)malloc(sizeof(struct thread_pool));
201 pthread_mutex_init(&(pool->tcb_lock), NULL);//初始为未锁住状态
202 pool->fDestroyed = 0;//线程池是否被销毁
203 pool->nFinish = 0;
204 pool->nowRunThread = NULL;//指向当前正在运行的线程 
205 pool->rrQueue.f = pool->rrQueue.r = 0;//轮转队列
206 pool->showQueue.r = pool->showQueue.r = 0;//用于辅助打印的队列
207 pool->tcb = NULL;
208 //创建并初始化TCB
209 TCB* ptemp = pool->tcb;
210 srand(time(0));
211 for(int i=0; i<THREAD_MAXN-1; ++i)
212 {
213     TCB* s = (TCB*)malloc(sizeof(TCB));
214    // s->arriveTime = rand()%9;
215     s->arriveTime = 0;
216     s->runTime = 10;
217     s->thread_id = i;//编号令为0
218     s->Finished = false;
219     s->next = NULL;
220     //尾插入
221     if(!pool->tcb)//第一个节点
222     {
223         pool->tcb = s;
224     }
225     else
226     {
227         ptemp = pool->tcb;
228         while(ptemp && ptemp->next)
229         {
230             ptemp = ptemp->next;
231         }
232         ptemp->next = s;
233     }
234 }
235 //初始化信号量sem
236 ptemp = pool->tcb;
237 int i=0;
238 while(ptemp != NULL)
239 {
240     int i = ptemp->thread_id;
241     sem_init(&i, 0, 0);
242     ptemp = ptemp->next;
243 }
244 //创建线程
245 ptemp = pool->tcb;
246 pool->threadid = (pthread_t*)malloc(sizeof(pthread_t) * THREAD_MAXN);
247 while(ptemp != NULL)
248 {
249     //把ptemp作为参数传入thread_run_func()
250     int t;
251     t = pthread_create(&(pool->threadid[ptemp->thread_id]), 
252                             NULL, thread_run_func, ptemp);
253     if(!t)//线程创建成功
254     {
255         printf("线程%d创建成功!
", ptemp->thread_id);
256     }
257     else
258     {
259         printf("线程创建失败!
");
260     }
261     ptemp = ptemp->next;
262 }
263 printf("线程池pool初始化完成！
");
264 }
265 void thread_run_func(void *param)//线程里运行的函数
266 {
267 TCB *ptemp = (TCB*)param;
268 // prtinf("线程%d开始了", ptemp->thread_id);
269 while(ptemp->runTime > 0)
270 {
271     printf("线程%d正在等待……
", ptemp->thread_id);
272     sleep(1);
273     sem_wait(&(pool->sem[ptemp->thread_id]));//唤醒
274     printf("线程%d已被唤醒！
",ptemp->thread_id);
275     pthread_mutex_lock(&(pool->tcb_lock));//上互斥锁
276     ptemp->runTime -= RUNTIME_SUB;
277     //线程操作
278     printf("---------------------------------4
");
279     // for(int i=0; i<STU_NUM; ++i)
280     // {
281 printf("---------------------------------12
");
282         int i=stuCnt;
283         struct free_block *pFree = free_queue;
284         struct busy_block *pBusy = busy_queue;
285 
286         printf("---------------------------------6
");
287         if(ptemp->thread_id == 0)//store number
288         {printf("---------------------------------13
");
289             if(i!=0 && student_info[i-1].name_stored)
290             {printf("---------------------------------14
");
291                 int fEnough = 0;
292                 while(pFree && !fEnough)
293                 {
294                     FF_bubble();
295 printf("---------------------------------16
");
296                     //BF_bubble();
297                     //WF_bubble();   
298                     if(pFree->next)
299                     {
300                         merge_free(pFree, pFree->next);//紧缩
301                     }
302                     if(pFree->size >= 8)
303                     {printf("---------------------------------18
");
304                         fEnough = 1;
305                         pBusy = create_busy(pFree->start, 8, NULL, student_info[i].number);
306                         delete_free(pFree);
307                         insert_busy(pBusy);
308                     }
309                     if(!fEnough)//FIFO
310                     {printf("---------------------------------fifo
");
311                         pBusy = busy_queue;
312                         printf("被调出的信息：id=%d，start=%d，size=%d，info：",pBusy->id, pBusy->start, pBusy->size);
313                         for(int j=0; j<pBusy->size; ++j)
314                         {
315                             printf("%c",pBusy->data[j]);
316                         }
317                         pFree = create_free(pBusy->start, pBusy->start, NULL);
318                         insert_free(pFree);
319                         delete_busy();
320                         printf("
");
321                     } 
322                     pFree = pFree->next;
323                 }  
324             }
325                 student_info[i].number_stored = 1;
326                printf("---------------------------------7
");
327         }
328         else//store name
329         {
330         printf("---------------------------------15
");
331 pFree = free_queue;
332 pBusy = busy_queue;
333             if(student_info[i].number_stored)
334             {
335 printf("---------------------------------20
");
336                 int fEnough = 0;
337                 int cnt = 0;
338                 while(pFree && !fEnough)
339                 {
340 cnt++;
341 if(cnt == 20)break;
342                     FF_bubble();
343                     printf("---------------------------------312
");
344                     printf("%d  %d %d
",free_queue->size, student_info[i].name_size,cnt);
345                     //BF_bubble();
346                     //WF_bubble();   
347                     printf("---------------------------------321312
");
348                     if(pFree->next)
349                     {
350 printf("---------------------------------22
");
351                         merge_free(pFree, pFree->next);//紧缩
352                     }
353                     if(pFree->size >= student_info[i].name_size)
354                     {
355                         fEnough = 1;
356                         pBusy = create_busy(pFree->start, student_info[i].name_size, NULL, student_info[i].name);
357                         delete_free(pFree);
358                         insert_busy(pBusy);
359 printf("---------------------------------23
");
360             
361                         if(!fEnough)//FIFO
362                         {
363                             pBusy = busy_queue;
364                             printf("被调出的信息：id=%d，start=%d，size=%d，info：",pBusy->id, pBusy->start, pBusy->size);
365                             for(int j=0; j<pBusy->size; ++j)
366                             {
367                                 printf("%c",pBusy->data[j]);
368                             }
369                             pFree = create_free(pBusy->start, pBusy->start, NULL);
370                             insert_free(pFree);
371                             delete_busy();
372                             printf("
");
373                         } 
374                          pFree = pFree->next;
375                     }  
376             }
377                 ++stuCnt;
378                 student_info[i].name_stored = 1;
379                printf("---------------------------------7
");
380           }
381         }
382 //}              
383   free(pFree);
384                 free(pBusy);
385     printf("---------------------------------5
");
386     //线程操作  
387     printf("当前时间为：%d，轮转的线程为线程%d，该线程剩余时间：%d->%d
",
388             nowTime, ptemp->thread_id, ptemp->runTime+RUNTIME_SUB, ptemp->runTime<0?0:ptemp->runTime);
389     sleep(1);
390     if(ptemp->runTime <= 0)//线程已经完成
391     {
392         ++pool->nFinish;
393         ptemp->Finished = true;
394         //出队
395         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
396     }
397     else
398     {//还未完成
399         //出队
400         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
401         //入队
402         pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
403         pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
404     }
405     printf("---------------------------------9
");
406     pthread_mutex_unlock(&(pool->tcb_lock));
407     sleep(1);
408 }
409 pthread_exit(NULL);
410 }
411 void round_robin()//时间片轮转算法的调度函数
412 {
413     TCB *ptemp = pool->tcb;
414     while(1)
415     {
416         sleep(1);
417         pthread_mutex_lock(&(pool->tcb_lock));
418         if(pool->nFinish == THREAD_MAXN-1)//所有线程完成
419             break;
420         while(ptemp && ptemp->arriveTime == nowTime)
421         {
422             printf("当前时间为：%d，线程%d进入轮转队列，运行时间：%d
", 
423             nowTime, ptemp->thread_id, ptemp->runTime);
424             pool->rrQueue.r = (pool->rrQueue.r+1)%THREAD_MAXN;
425             pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
426             ptemp = ptemp->next;
427         }
428         if(pool->rrQueue.f != pool->rrQueue.r)
429         {
430             pool->nowRunThread = pool->rrQueue.tcbQueue[(pool->rrQueue.f+1)%THREAD_MAXN];
431             printf("准备唤醒线程%d
",pool->nowRunThread->thread_id);
432             sleep(1);
433             sem_post(&(pool->sem[pool->nowRunThread->thread_id]));
434         }
435         show_rr();
436         ++nowTime;
437         pthread_mutex_unlock(&(pool->tcb_lock));
438         sleep(1);
439     }
440 }
441 int pool_destroy()//销毁线程池
442 {
443     if(pool->fDestroyed)//防止重复销毁
444         return -1;
445     pool->fDestroyed = 1;
446     TCB* ptemp = pool->tcb;
447     while(ptemp)
448     {
449         pthread_join(pool->threadid[ptemp->thread_id], NULL);
450         printf("线程%d已结束
",ptemp->thread_id);
451         ptemp = ptemp->next;
452     }
453     free(ptemp);
454     free(pool->threadid);
455     pthread_mutex_destroy(&(pool->tcb_lock));
456     free(pool);
457     pool = NULL;
458     printf("线程池pool已被销毁！
");
459 }
460 
461 //----------------------------------------------------------------------------------
462 
463 void init_free()
464 {
465     int start_address = 0;
466     struct free_block *ptemp = NULL;
467     for(int i=0; i<INIT_FREE_BLOCK_NUM; ++i)
468     {
469         struct free_block* s = create_free(start_address, INIT_FREE_BLOCK_SIZE, NULL);
470         ++nFree;
471         if(free_queue == NULL)
472         {
473             free_queue = s;
474             printf("---------------------------------10
");
475         }
476         else
477         {
478             ptemp = free_queue;
479             printf("---------------------------------11
");
480             while(ptemp && ptemp->next)
481             {
482                 ptemp = ptemp->next;
483             }
484             ptemp->next = s;
485             printf("---------------------------------11
");
486         }
487         start_address += INIT_FREE_BLOCK_SIZE;
488     }
489     printf("空闲内存块初始化完成！
");
490     show_free();
491 }
492 struct free_block* create_free(int start, int size, struct free_block *next)
493 {
494     struct free_block *s = (struct free_block*)malloc(sizeof(struct free_block));
495     s->start = start;
496     s->size = size;
497     s->next = next;
498     return s;
499 }
500 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data)
501 {
502     struct busy_block *s = (struct busy_block*)malloc(sizeof(struct busy_block));
503     s->start = start;
504     s->id = ++busy_id;
505     s->next = next;
506     s->size = size;
507     s->data = (char*)malloc(sizeof(char) * size);
508     for(int i=0; i<size; ++i)
509     {
510         s->data[i] = data[i];
511     }   
512     ++nBusy;
513 }
514 struct free_block * merge_free(struct free_block *f1, struct free_block *f2)
515 {
516     if(f1->start + f1->size != f2->start )
517     {
518         return f1;
519     }
520     else
521     {
522         f1->size += f2->size;
523         f1->next = f2->next;
524         free(f2);
525         f2 = NULL;
526         --nFree;
527         return f1;
528     }
529 }
530 
531 void init_student()
532 {
533     srand(time(0));
534     for(int i=0; i<STU_NUM; ++i)
535     {
536         strcpy(student_info[i].number, "201820");
537         if(i < 10)
538         {
539             student_info[i].number[6] = 0;
540             student_info[i].number[7] = i;
541         }
542         else
543         {
544             student_info[i].number[6] = i/10;
545             student_info[i].number[7] = i%10;
546         }
547         int n = 4;
548         n += rand()%20;
549         student_info[i].name_size = n;
550         for(int j=0; j<n; ++j)
551         {
552             student_info[i].name[j] = 'a'+ i;
553         }
554         student_info[i].name_stored = 0;
555         student_info[i].number_stored = 0;
556     }
557     printf("学生信息初始化完成！
");
558 }
559 
560 void FF_bubble()
561 {
562 struct free_block* ptemp = NULL;
563 for(int i=0; i<nFree; ++i)
564 {
565     ptemp = free_queue; 
566     while(ptemp && ptemp->next)
567     {
568         if(ptemp->start > ptemp->next->start )
569         {//交换两个节点
570             struct free_block *p_next = ptemp->next->next;
571             struct free_block *p_pre = ptemp;
572             struct free_block *p_pre_pre = pool->tcb;
573             if(p_pre_pre == p_pre)
574             {
575                 p_pre_pre = NULL;
576             }
577             else
578             {
579                 while(p_pre_pre && p_pre_pre->next != p_pre)
580                 {
581                     p_pre_pre = p_pre_pre->next;
582                 }
583             }
584             ptemp = ptemp->next;
585             ptemp->next = p_pre;
586             p_pre->next = p_next;
587             if(p_pre_pre)
588             {
589                 p_pre_pre->next = ptemp;
590             }
591             else
592             {
593                 pool->tcb = ptemp;
594             } 
595         }
596         ptemp = ptemp->next;
597     }    
598 }
599 }
600 
601 void BF_bubble()
602 {
603 struct free_block* ptemp = NULL;
604 for(int i=0; i<nFree; ++i)
605 {
606     ptemp = free_queue; 
607     while(ptemp && ptemp->next)
608     {
609         if(ptemp->size > ptemp->next->size)
610         {//交换两个节点
611             struct free_block *p_next = ptemp->next->next;
612             struct free_block *p_pre = ptemp;
613             struct free_block *p_pre_pre = pool->tcb;
614             if(p_pre_pre == p_pre)
615             {
616                 p_pre_pre = NULL;
617             }
618             else
619             {
620                 while(p_pre_pre && p_pre_pre->next != p_pre)
621                 {
622                     p_pre_pre = p_pre_pre->next;
623                 }
624             }
625             ptemp = ptemp->next;
626             ptemp->next = p_pre;
627             p_pre->next = p_next;
628             if(p_pre_pre)
629             {
630                 p_pre_pre->next = ptemp;
631             }
632             else
633             {
634                 pool->tcb = ptemp;
635             } 
636         }
637         ptemp = ptemp->next;
638     }    
639 }
640 }
641 
642 void WF_bubble()
643 {
644 struct free_block* ptemp = NULL;
645 for(int i=0; i<nFree; ++i)
646 {
647     ptemp = free_queue; 
648     while(ptemp && ptemp->next)
649     {
650         if(ptemp->size < ptemp->next->size)
651         {//交换两个节点
652             struct free_block *p_next = ptemp->next->next;
653             struct free_block *p_pre = ptemp;
654             struct free_block *p_pre_pre = pool->tcb;
655             if(p_pre_pre == p_pre)
656             {
657                 p_pre_pre = NULL;
658             }
659             else
660             {
661                 while(p_pre_pre && p_pre_pre->next != p_pre)
662                 {
663                     p_pre_pre = p_pre_pre->next;
664                 }
665             }
666             ptemp = ptemp->next;
667             ptemp->next = p_pre;
668             p_pre->next = p_next;
669             if(p_pre_pre)
670             {
671                 p_pre_pre->next = ptemp;
672             }
673             else
674             {
675                 pool->tcb = ptemp;
676             } 
677         }
678         ptemp = ptemp->next;
679     }    
680 }
681 }
682 
683 void insert_busy(struct busy_block *pBusy)
684 {
685     struct busy_block *ptemp = busy_queue;
686     while(ptemp)
687     {
688         ptemp = ptemp->next;
689     }
690     ptemp->next = pBusy;
691 }
692 
693 void insert_free(struct free_block *pFree)
694 {
695     struct free_block *ptemp = free_queue;
696     while(ptemp)
697     {
698         ptemp = ptemp->next;
699     }
700     ptemp->next = pFree;
701 }
702 
703 void delete_free(struct free_block *pFree)
704 {
705     struct free_block *ptemp = free_queue;
706     struct free_block *pre = NULL;
707     while(ptemp)
708     {
709         if(ptemp == pFree)
710         {
711             break;
712         }
713         pre = ptemp;
714         ptemp = ptemp->next;
715     }
716     pre->next = ptemp->next;
717 }
718 
719 void delete_busy()
720 {
721     struct busy_block *ptemp = busy_queue;
722     busy_queue = busy_queue->next;
723     free(ptemp);
724 }
725 
726 void show_free()
727 {
728     struct free_block *ptemp = free_queue;
729     printf("显示空闲块：
");
730     while(ptemp)
731     {
732         printf("开始：%d，大小：%d",ptemp->start, ptemp->size);
733         ptemp = ptemp->next;
734     }
735     printf("
");
736 }
737 
738 void show_busy()
739 {
740     struct free_block *ptemp = busy_queue;
741     printf("显示已分配块：
");
742     while(ptemp)
743     {
744         printf("开始：%d，大小：%d",ptemp->start, ptemp->size);
745         ptemp = ptemp->next;
746     }
747     printf("
");
748 }

temp1

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <string.h>
  4 #include <semaphore.h>
  5 #include <unistd.h>
  6 #include <time.h>
  7 #include <sys/types.h>
  8 #include <pthread.h>
  9 #define bool int
 10 #define true 1
 11 #define false 0
 12 #define THREAD_MAXN 3//线程数
 13 #define RUNTIME_SUB 1//每次运行线程减去的运行时间
 14 #define RUN_TIME 22
 15 #define INIT_FREE_BLOCK_NUM 8
 16 #define INIT_FREE_BLOCK_SIZE 10
 17 #define FREE_MAXN 100
 18 #define STU_NUM 20
 19 //-----结构体定义
 20 typedef struct TCB//存储线程信息
 21 {
 22     int thread_id;//线程编号
 23     int arriveTime;//线程到达时间
 24     int runTime;//持续时间
 25     int finishTime;//完成时间
 26     int wholeTime;//周转时间
 27     double weightWholeTime;//带权周转时间
 28     bool Finished;//线程是否完成
 29     struct TCB* next;//使用链式存储方式
 30 }TCB;
 31 struct tcb_queue//TCB队列定义
 32 {
 33     struct TCB* tcbQueue[THREAD_MAXN];//TCB指针数组
 34     int r,f;
 35 };
 36 struct thread_pool//线程池结构体
 37 {
 38     pthread_mutex_t tcb_lock;//互斥锁
 39     int fDestroyed;//线程池是否被销毁
 40     pthread_t *threadid;//存储线程标识符指针
 41     struct TCB *nowRunThread;//指向当前正在运行的线程     
 42     int nFinish;//完成线程数
 43     sem_t sem[THREAD_MAXN];//用于控制线程的信号量
 44     sem_t sem_0_1;//线程0对线程1的控制
 45     struct tcb_queue rrQueue;//轮转队列
 46     struct tcb_queue showQueue;//用于辅助打印的队列
 47     struct TCB *tcb;//存储TCB
 48 };
 49 struct free_block
 50 {
 51     int start;
 52     int size;
 53     struct free_block *next;
 54 };
 55 struct busy_block
 56 {
 57     int id;//编号
 58     int start;
 59     int size;
 60     char *data;//根据需要动态分配
 61     struct busy_blocl *next;
 62 };
 63 struct student
 64 {
 65     char number[9];
 66     char name[21];
 67     int name_size;
 68     int number_stored;
 69     int name_stored;
 70 };
 71 //-----全局变量定义
 72 static struct thread_pool *pool = NULL;//全局变量pool，指向线程池
 73 int nowTime;//当前已走过的时间
 74 int busy_id = -1;
 75 int nFree = 0;
 76 int nBusy = 0;
 77 int stuCnt = 0;
 78 int nameCnt = 0;
 79 int numCnt = 0;
 80 struct free_block *free_queue = NULL;
 81 struct busy_block *busy_queue = NULL;
 82 struct student student_info[STU_NUM];
 83 //-----函数声明
 84 void bubble_sort();//给TCB排序
 85 void show_rr();//打印轮转队列
 86 void show_tcb();//打印所有线程的信息
 87 void pool_init();//初始化线程池
 88 void thread_run_func(void* param);//线程里运行的函数
 89 void round_robin();//时间片轮转算法的调度函数
 90 int pool_destroy();//销毁线程池
 91 void init_free();
 92 struct free_block* create_free(int start, int size, struct free_block *next);
 93 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data);
 94 struct free_block * merge_free(struct free_block *f);
 95 void init_student();
 96 void insert_busy(struct busy_block *pBusy);
 97 void insert_free(struct free_block *pFree);
 98 void delete_free(struct free_block *pFree, struct free_block *pLeft);
 99 void delete_busy();
100 void show_free();
101 void show_busy();
102 void FF_bubble();
103 void BF_bubble();
104 void WF_bubble();
105 void merge_in();
106 void fifo();
107 //main
108 int main()
109 {
110     init_free();
111     printf("---------------------------------1
");
112     init_student();
113     printf("---------------------------------2
");
114     pool_init();
115     printf("---------------------------------3
");
116     printf("打印初始TCB：
");
117     show_tcb();
118     printf("TCB按到达时间排序后：
");
119     bubble_sort();
120     show_tcb();
121     printf("使用时间片轮转算法调度:
");
122     round_robin();
123     sleep(5);//等待所有线程完成
124     pool_destroy();
125     return 0;
126 }
127 //函数定义
128 void bubble_sort()//给TCB排序,按arriveTime升序排列
129 {
130 TCB* ptemp = NULL;
131 for(int i=0; i<THREAD_MAXN; ++i)
132 {
133     ptemp = pool->tcb;
134     while(ptemp && ptemp->next)
135     {
136         if(ptemp->arriveTime > ptemp->next->arriveTime)
137         {//交换两个节点
138             TCB *p_next = ptemp->next->next;
139             TCB *p_pre = ptemp;
140             TCB *p_pre_pre = pool->tcb;
141             if(p_pre_pre == p_pre)
142             {
143                 p_pre_pre = NULL;
144             }
145             else
146             {
147                 while(p_pre_pre && p_pre_pre->next != p_pre)
148                 {
149                     p_pre_pre = p_pre_pre->next;
150                 }
151             }
152             ptemp = ptemp->next;
153             ptemp->next = p_pre;
154             p_pre->next = p_next;
155             if(p_pre_pre)
156             {
157                 p_pre_pre->next = ptemp;
158             }
159             else
160             {
161                 pool->tcb = ptemp;
162             } 
163         }
164         ptemp = ptemp->next;
165     }    
166 }
167 }
168 void show_rr()//打印轮转队列
169 {
170 printf("当前时间为：%d
",nowTime);
171 if(pool->rrQueue.f == pool->rrQueue.r)
172 {
173     printf("目前还没有线程到达
");
174 }
175 else
176 {
177     printf("目前轮转队列为：
");
178 }
179 while(pool->rrQueue.f != pool->rrQueue.r)
180 {
181     pool->showQueue.f = (pool->showQueue.f + 1) % THREAD_MAXN;
182     pool->rrQueue.f = (pool->rrQueue.f + 1) % THREAD_MAXN;
183     pool->showQueue.tcbQueue[pool->showQueue.f] = pool->rrQueue.tcbQueue[pool->rrQueue.f];
184     printf("%d ",pool->rrQueue.tcbQueue[pool->rrQueue.f]->thread_id);
185 }
186 while(pool->showQueue.r != pool->showQueue.f)//将队列放回
187 {
188     pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
189     pool->showQueue.r = (pool->showQueue.r + 1) % THREAD_MAXN;
190     pool->rrQueue.tcbQueue[pool->rrQueue.r] = pool->showQueue.tcbQueue[pool->showQueue.r];
191 }
192 printf("

");
193 }
194 void show_tcb()//打印所有线程的信息
195 {
196 TCB *ptemp = pool->tcb;
197 printf("打印所有线程的信息：
");
198 while(ptemp)
199 {
200     printf("线程%d：到达时间：%d，剩余时间：%d
", ptemp->thread_id, ptemp->arriveTime, ptemp->runTime);
201     ptemp = ptemp->next;
202 }
203 printf("
");
204 }
205 void pool_init()//初始化线程池
206 {
207 pool = (struct thread_pool*)malloc(sizeof(struct thread_pool));
208 pthread_mutex_init(&(pool->tcb_lock), NULL);//初始为未锁住状态
209 pool->fDestroyed = 0;//线程池是否被销毁
210 pool->nFinish = 0;
211 pool->nowRunThread = NULL;//指向当前正在运行的线程 
212 pool->rrQueue.f = pool->rrQueue.r = 0;//轮转队列
213 pool->showQueue.r = pool->showQueue.r = 0;//用于辅助打印的队列
214 pool->tcb = NULL;
215 //创建并初始化TCB
216 TCB* ptemp = pool->tcb;
217 srand(time(0));
218 for(int i=0; i<THREAD_MAXN-1; ++i)
219 {
220     TCB* s = (TCB*)malloc(sizeof(TCB));
221    // s->arriveTime = rand()%9;
222     s->arriveTime = 0;
223     s->runTime = RUN_TIME;
224     s->thread_id = i;//编号令为0
225     s->Finished = false;
226     s->next = NULL;
227     //尾插入
228     if(!pool->tcb)//第一个节点
229     {
230         pool->tcb = s;
231     }
232     else
233     {
234         ptemp = pool->tcb;
235         while(ptemp && ptemp->next)
236         {
237             ptemp = ptemp->next;
238         }
239         ptemp->next = s;
240     }
241 }
242 //初始化信号量
243 ptemp = pool->tcb;
244 int i=0;
245 while(ptemp != NULL)
246 {
247     int i = ptemp->thread_id;
248     sem_init(&(pool->sem[i]), 0, 0);
249     ptemp = ptemp->next;
250 }
251 sem_init(&(pool->sem_0_1), 0, 1);
252 //创建线程
253 ptemp = pool->tcb;
254 pool->threadid = (pthread_t*)malloc(sizeof(pthread_t) * THREAD_MAXN);
255 while(ptemp != NULL)
256 {
257     //把ptemp作为参数传入thread_run_func()
258     int t;
259     t = pthread_create(&(pool->threadid[ptemp->thread_id]), 
260                             NULL, thread_run_func, ptemp);
261     if(!t)//线程创建成功
262     {
263         printf("线程%d创建成功!
", ptemp->thread_id);
264     }
265     else
266     {
267         printf("线程创建失败!
");
268     }
269     ptemp = ptemp->next;
270 }
271 printf("线程池pool初始化完成！
");
272 }
273 void thread_run_func(void *param)//线程里运行的函数
274 {
275 TCB *ptemp = (TCB*)param;
276 // prtinf("线程%d开始了", ptemp->thread_id);
277 while(ptemp->runTime > 0)
278 {
279     printf("线程%d正在等待……
", ptemp->thread_id);
280     sleep(1);
281     sem_wait(&(pool->sem[ptemp->thread_id]));//唤醒
282     printf("线程%d已被唤醒！
",ptemp->thread_id);
283     pthread_mutex_lock(&(pool->tcb_lock));//上互斥锁
284     ptemp->runTime -= RUNTIME_SUB;
285     //线程操作
286     printf("---------------------------------4
");
287     // for(int i=0; i<STU_NUM; ++i)
288     // {
289         int i = numCnt;
290         int j = nameCnt;
291         struct free_block *pFree = NULL;
292         struct busy_block *pBusy = NULL;
293         if(ptemp->thread_id == 0)//store number
294         {  
295             printf("想插入：number:");
296             for(int c=0; c<8; ++c)
297             {
298                 printf("%c",student_info[i].number[c]);
299             }
300             printf("
");
301             pFree = free_queue;
302             pBusy = busy_queue;
303             printf("---------------------------------13
");
304             sleep(1);//等待标志被赋值
305             printf("student_info[%d].name_stored = %d
",i-1,student_info[i-1].name_stored);
306 
307                 printf("---------------------------------14
");
308                 int fEnough = 0;
309                 while(!fEnough)
310                 {
311                    if(free_queue)
312                    {
313                         FF_bubble();
314                         printf("---------------------------------16
");
315                         //BF_bubble();
316                         //WF_bubble();   
317                         printf("紧缩：
");
318                         merge_in();//紧缩
319                    }
320                     //printf("pFree->size:%d
",pFree->size);
321                     show_free();
322                     if(pFree && pFree->size >= 8 )
323                     {
324                         show_free();
325                         printf("---------------------------------18
");
326                         fEnough = 1;
327                         student_info[i].number_stored = 1;
328                         printf("set student_info[%d].number_stored = %d
", i,student_info[i].number_stored);
329                         pBusy = create_busy(pFree->start, 8, NULL, student_info[i].number);
330                         printf("已存储信息：start:%d, size:%d
",pFree->start, pFree->size);
331                         printf("---------------------------------181
");
332                         ++numCnt;
333                         struct free_block *pLeft = create_free(pFree->start+8, pFree->size-8, pFree->next);
334                         delete_free(pFree, pLeft);
335                         show_free();
336                         printf("-----------------插入前--------------182
");
337                         show_busy();
338                         insert_busy(pBusy);
339                         printf("----------------插入后--------------183
");
340                         show_busy();
341                         break;
342                     }
343                     else
344                     {
345                         if(pFree)
346                         {
347                             pFree = pFree->next;
348                         }
349                         else
350                         {
351                             fifo();
352                             pFree = free_queue;
353                         }
354                     }
355                       printf("---------------------------------185
");
356                 }  
357                   printf("---------------------------------186
");
358         }
359         else//store name
360     {  
361             printf("想插入：name:");
362             for(int c=0; c<student_info[j].name_size; ++c)
363             {
364                 printf("%c",student_info[j].name[c]);
365             }
366             printf("
");
367             pFree = free_queue;
368             pBusy = busy_queue;
369             printf("---------------------------------a13
");
370             sleep(1);//等待标志被赋值
371             printf("student_info[%d].number_stored = %d
",j,student_info[j].number_stored);
372            //     if(student_info[i].number_stored)
373              //   {
374                     printf("---------------------------------a14
");
375                     int fEnough = 0;
376                     while(!fEnough)
377                     {
378                         if(free_queue)
379                         {
380                                 FF_bubble();
381                                 printf("---------------------------------16
");
382                                 //BF_bubble();
383                                 //WF_bubble();   
384                                 printf("紧缩：
");
385                                 merge_in();//紧缩
386                         }
387                         show_free();
388                         printf("---------------------------------aa1
");
389                         if(pFree && pFree->size >= student_info[j].name_size )
390                         {   
391                             printf("---------------------------------aa2
");
392                             show_free();
393                             printf("---------------------------------a18
");
394                             fEnough = 1;
395                             ++nameCnt;
396                             student_info[j].number_stored = 1;
397                             printf("set student_info[%d].name_stored = %d
",j,student_info[j].name_stored);
398                             pBusy = create_busy(pFree->start, student_info[j].name_size, NULL, student_info[j].name);
399                             printf("已存储信息：start:%d, size:%d
",pFree->start, pFree->size);
400                             printf("---------------------------------181
");
401                             
402                             struct free_block *pLeft = create_free(pFree->start+student_info[j].name_size,
403                                                         pFree->size-student_info[j].name_size, pFree->next);
404                             delete_free(pFree, pLeft);
405                             show_free();
406                             printf("----------插入前---------------------a182
");
407                             show_busy();
408                             insert_busy(pBusy);
409                             printf("-----------插入后-----------------a183
");
410                             show_busy();
411                             break;
412                         }
413                         else
414                         {
415                             if(pFree)
416                             {
417                                 pFree = pFree->next;
418                             }
419                             else//FIFO
420                             {
421                                 fifo();
422                                 pFree = free_queue;
423                             }
424                         }
425                         printf("---------------------------------a185, fifo
");
426                         sleep(1);
427                     }  
428                     printf("---------------------------------a186
");
429              //   }
430                printf("---------------------------------a7
");
431     }
432     printf("---------------------------------88
");
433     //线程操作  
434     printf("当前时间为：%d，轮转的线程为线程%d，该线程剩余时间：%d->%d
",
435             nowTime, ptemp->thread_id, ptemp->runTime+RUNTIME_SUB, ptemp->runTime<0?0:ptemp->runTime);
436     sleep(1);
437     if(ptemp->runTime <= 0)//线程已经完成
438     {
439         ++pool->nFinish;
440         ptemp->Finished = true;
441         //出队
442         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
443     }
444     else
445     {//还未完成
446         //出队
447         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
448         //入队
449         pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
450         pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
451     }
452     printf("---------------------------------9
");
453     pthread_mutex_unlock(&(pool->tcb_lock));
454     sleep(1);
455 }
456 pthread_exit(NULL);
457 }
458 void round_robin()//时间片轮转算法的调度函数
459 {
460     TCB *ptemp = pool->tcb;
461     while(1)
462     {
463         sleep(1);
464         pthread_mutex_lock(&(pool->tcb_lock));
465         if(pool->nFinish == THREAD_MAXN-1)//所有线程完成
466             break;
467         while(ptemp && ptemp->arriveTime == nowTime)
468         {
469             printf("当前时间为：%d，线程%d进入轮转队列，运行时间：%d
", 
470             nowTime, ptemp->thread_id, ptemp->runTime);
471             pool->rrQueue.r = (pool->rrQueue.r+1)%THREAD_MAXN;
472             pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
473             ptemp = ptemp->next;
474         }
475         if(pool->rrQueue.f != pool->rrQueue.r)
476         {
477             pool->nowRunThread = pool->rrQueue.tcbQueue[(pool->rrQueue.f+1)%THREAD_MAXN];
478             printf("准备唤醒线程%d
",pool->nowRunThread->thread_id);
479             sleep(1);
480             sem_post(&(pool->sem[pool->nowRunThread->thread_id]));
481         }
482         show_rr();
483         ++nowTime;
484         pthread_mutex_unlock(&(pool->tcb_lock));
485         sleep(1);
486     }
487 }
488 int pool_destroy()//销毁线程池
489 {
490     if(pool->fDestroyed)//防止重复销毁
491         return -1;
492     pool->fDestroyed = 1;
493     TCB* ptemp = pool->tcb;
494     while(ptemp)
495     {
496         pthread_join(pool->threadid[ptemp->thread_id], NULL);
497         printf("线程%d已结束
",ptemp->thread_id);
498         ptemp = ptemp->next;
499     }
500     free(ptemp);
501     free(pool->threadid);
502     pthread_mutex_destroy(&(pool->tcb_lock));
503     free(pool);
504     pool = NULL;
505     printf("线程池pool已被销毁！
");
506 }
507 
508 //----------------------------------------------------------------------------------
509 
510 void init_free()
511 {
512     int start_address = 0;
513     struct free_block *ptemp = NULL;
514     for(int i=0; i<INIT_FREE_BLOCK_NUM; ++i)
515     {
516         struct free_block* s = create_free(start_address, INIT_FREE_BLOCK_SIZE, NULL);
517     printf("------------create_free------%d, %d
", s->start, s->size);
518         ++nFree;
519         if(free_queue == NULL)
520         {
521             free_queue = s;
522             printf("---------------------------------10
");
523         }
524         else
525         {
526             ptemp = free_queue;
527             printf("---------------------------------11
");
528             while(ptemp && ptemp->next)
529             {
530                 ptemp = ptemp->next;
531             }
532             ptemp->next = s;
533         }
534         start_address += INIT_FREE_BLOCK_SIZE;
535     }
536     printf("空闲内存块初始化完成！
");
537     show_free();
538 }
539 struct free_block* create_free(int start, int size, struct free_block *next)
540 {
541     struct free_block *s = (struct free_block*)malloc(sizeof(struct free_block));
542     s->start = start;
543     s->size = size;
544     s->next = next;
545     return s;
546 }
547 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data)
548 {
549     struct busy_block *s = (struct busy_block*)malloc(sizeof(struct busy_block));
550     s->start = start;
551     s->id = ++busy_id;
552     s->next = NULL;
553     s->size = size;
554     s->data = (char*)malloc(sizeof(char) * size);
555     for(int i=0; i<size; ++i)
556     {
557         s->data[i] = data[i];
558     }   
559     ++nBusy;
560     return s;
561 }
562 
563 void init_student()
564 {
565     srand(time(0));
566     for(int i=0; i<STU_NUM; ++i)
567     {
568         strcpy(student_info[i].number, "201820");
569         if(i < 10)
570         {
571             student_info[i].number[6] = '0';
572             student_info[i].number[7] = '0' + i;
573         }
574         else
575         {
576             student_info[i].number[6] = '0' + i/10;
577             student_info[i].number[7] = '0' + i%10;
578         }
579     student_info[i].number[8] = '';
580         int n = 4;
581            int ran = rand()%20;
582     printf("rand : %d
",ran);
583     n = n + ran;
584     printf("n : %d
", n);
585         student_info[i].name_size = n;
586         for(int j=0; j<n; ++j)
587         {
588             student_info[i].name[j] = (char)('a' + i);
589         }
590     student_info[i].name[n] = '';
591         student_info[i].name_stored = 0;
592         student_info[i].number_stored = 0;
593         printf("student:%d %s, %d, %s
", i,student_info[i].name, student_info[i].name_size, student_info[i].number);
594     }
595     printf("学生信息初始化完成！
");
596 }
597 
598 void FF_bubble()
599 {
600     struct free_block* ptemp = NULL;
601 if(free_queue!=NULL)
602     for(int i=0; i<FREE_MAXN; ++i)
603     {
604         ptemp = free_queue; 
605         while(ptemp && ptemp->next)
606         {
607             if(ptemp->start > ptemp->next->start )
608             {//交换两个节点
609                 struct free_block *p_next = ptemp->next->next;
610                 struct free_block *p_pre = ptemp;
611                 struct free_block *p_pre_pre = free_queue;
612                 if(p_pre_pre == p_pre)
613                 {
614                     p_pre_pre = NULL;
615                 }
616                 else
617                 {
618                     while(p_pre_pre && p_pre_pre->next != p_pre)
619                     {
620                         p_pre_pre = p_pre_pre->next;
621                     }
622                 }
623                 ptemp = ptemp->next;
624                 ptemp->next = p_pre;
625                 p_pre->next = p_next;
626                 if(p_pre_pre)
627                 {
628                     p_pre_pre->next = ptemp;
629                 }
630                 else
631                 {
632                     free_queue = ptemp;
633                 } 
634             }
635             ptemp = ptemp->next;
636         }    
637     }
638 }
639 
640 void BF_bubble()
641 {
642 struct free_block* ptemp = NULL;
643 for(int i=0; i<nFree; ++i)
644 {
645     ptemp = free_queue; 
646     while(ptemp && ptemp->next)
647     {
648         if(ptemp->size > ptemp->next->size)
649         {//交换两个节点
650             struct free_block *p_next = ptemp->next->next;
651             struct free_block *p_pre = ptemp;
652             struct free_block *p_pre_pre = pool->tcb;
653             if(p_pre_pre == p_pre)
654             {
655                 p_pre_pre = NULL;
656             }
657             else
658             {
659                 while(p_pre_pre && p_pre_pre->next != p_pre)
660                 {
661                     p_pre_pre = p_pre_pre->next;
662                 }
663             }
664             ptemp = ptemp->next;
665             ptemp->next = p_pre;
666             p_pre->next = p_next;
667             if(p_pre_pre)
668             {
669                 p_pre_pre->next = ptemp;
670             }
671             else
672             {
673                 pool->tcb = ptemp;
674             } 
675         }
676         ptemp = ptemp->next;
677     }    
678 }
679 }
680 
681 void WF_bubble()
682 {
683 struct free_block* ptemp = NULL;
684 for(int i=0; i<nFree; ++i)
685 {
686     ptemp = free_queue; 
687     while(ptemp && ptemp->next)
688     {
689         if(ptemp->size < ptemp->next->size)
690         {//交换两个节点
691             struct free_block *p_next = ptemp->next->next;
692             struct free_block *p_pre = ptemp;
693             struct free_block *p_pre_pre = pool->tcb;
694             if(p_pre_pre == p_pre)
695             {
696                 p_pre_pre = NULL;
697             }
698             else
699             {
700                 while(p_pre_pre && p_pre_pre->next != p_pre)
701                 {
702                     p_pre_pre = p_pre_pre->next;
703                 }
704             }
705             ptemp = ptemp->next;
706             ptemp->next = p_pre;
707             p_pre->next = p_next;
708             if(p_pre_pre)
709             {
710                 p_pre_pre->next = ptemp;
711             }
712             else
713             {
714                 pool->tcb = ptemp;
715             } 
716         }
717         ptemp = ptemp->next;
718     }    
719 }
720 }
721 
722 void insert_busy(struct busy_block *pBusy)
723 {
724     if(busy_queue == NULL) 
725     {
726         busy_queue = pBusy;
727     }
728     else
729     {
730         struct busy_block *ptemp = busy_queue;
731         printf("--------busy insert1
");
732         while(ptemp && ptemp->next)
733         {
734              printf("--------busy insert2
");
735             ptemp = ptemp->next;
736         }
737          printf("--------busy insert3
");
738         ptemp->next = pBusy;
739     }
740 }
741 
742 void insert_free(struct free_block *pFree)
743 {
744     if(free_queue == NULL)
745     {
746         free_queue = pFree;
747     }
748     else
749     {
750         struct free_block *ptemp = free_queue;
751         while(ptemp && ptemp->next)
752         {
753             ptemp = ptemp->next;
754         }
755         ptemp->next = pFree;
756     }
757     
758 
759 }
760 
761 void delete_free(struct free_block *pFree, struct free_block *pLeft)
762 {
763     struct free_block *ptemp = free_queue;
764     struct free_block *pre = NULL;
765     if(ptemp == NULL)return;
766     
767     while(ptemp)
768     {
769         if(ptemp == pFree)
770         {
771             break;
772         }
773         pre = ptemp;
774         ptemp = ptemp->next;
775     }
776     if(pre)
777     {
778         if(pLeft->size == 0)
779         {
780             pre->next = ptemp->next;
781             free(pLeft);
782         }
783         else
784         {
785             pre->next = pLeft;
786         }
787         free(ptemp);
788     }
789     else
790     {
791         if(pLeft->size == 0)
792         {
793             free_queue = ptemp->next;
794             free(pLeft);
795         }       
796         else
797             free_queue = pLeft;
798 
799             free(ptemp);
800     }
801 }
802 
803 void delete_busy()
804 {
805     if(busy_queue)
806     {
807         struct busy_block *ptemp = busy_queue;
808         busy_queue = busy_queue->next;
809         free(ptemp);
810     }
811     else
812     {
813         printf("busy空
");
814     }
815 }
816 
817 void show_free()
818 {
819     printf("show free
");
820     if(free_queue)
821     {
822         struct free_block *ptemp = free_queue;
823         printf("显示空闲块：
");
824         while(ptemp != NULL)
825         {
826             printf("开始：%d，大小：%d
",ptemp->start, ptemp->size);
827             ptemp = ptemp->next;
828         }
829         printf("
");
830     }
831     else
832     {
833         printf("free is empty
");
834     }
835     
836 }
837 
838 void show_busy()
839 {
840     printf("show busy
");
841     if(busy_queue != NULL)
842     {
843         struct busy_block *ptemp = busy_queue;
844         printf("显示已分配块：
");
845         while(ptemp != NULL)
846         {
847              printf("--------show busy1
");
848             printf("id:%d，开始：%d，大小：%d
",ptemp->id, ptemp->start, ptemp->size);
849             ptemp = ptemp->next;
850             printf("--------show busy2
");
851         }    
852         printf("--------show busy3
");
853         printf("
");
854     }
855     else
856     {
857         printf("busy 空了
");
858     }
859 }
860 
861 void merge_in()
862 {
863     free_queue = merge_free(free_queue);
864     printf("缩完
");
865 }
866 
867 struct free_block * merge_free(struct free_block *f)
868 {
869     if(f && f->next)
870     {
871         f->next = merge_free(f->next);
872         if(f->next && (f->start + f->size == f->next->start))
873         {
874             struct free_block *p = f->next;
875             f->next = p->next;
876             f->size += p->size;
877             free(p);
878             p=NULL;
879         }
880     }
881     return f;
882 }
883 
884 void fifo()
885 {
886     if(busy_queue)
887     {
888         printf("---------------------------------afifo
");
889         printf("啊这
");
890         printf("调出1
");
891         printf("被调出的信息:start=%d，size=%d, info:", busy_queue->start, busy_queue->size);
892         for(int k=0; k<busy_queue->size; ++k)
893         {
894             printf("%c",busy_queue->data[k]);
895         }
896         printf("
");
897         struct free_queue *pFree = create_free(busy_queue->start, busy_queue->size, NULL);
898         printf("插入free
");
899         insert_free(pFree);
900         show_busy();
901         printf("调出2
");
902         show_free();
903         delete_busy();
904     }
905     else
906     {
907         printf("busy 已空，无法再调出
");
908     }
909 }

初版成品

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <string.h>
  4 #include <semaphore.h>
  5 #include <unistd.h>
  6 #include <time.h>
  7 #include <sys/types.h>
  8 #include <pthread.h>
  9 #define bool int
 10 #define true 1
 11 #define false 0
 12 #define THREAD_MAXN 3//线程数
 13 #define RUNTIME_SUB 1//每次运行线程减去的运行时间
 14 #define RUN_TIME 1000
 15 #define INIT_FREE_BLOCK_NUM 8
 16 #define INIT_FREE_BLOCK_SIZE 10
 17 #define FREE_MAXN 100
 18 #define STU_NUM 50
 19 //-----结构体定义
 20 typedef struct TCB//存储线程信息
 21 {
 22     int thread_id;//线程编号
 23     int arriveTime;//线程到达时间
 24     int runTime;//持续时间
 25     int finishTime;//完成时间
 26     int wholeTime;//周转时间
 27     double weightWholeTime;//带权周转时间
 28     bool Finished;//线程是否完成
 29     struct TCB* next;//使用链式存储方式
 30 }TCB;
 31 struct tcb_queue//TCB队列定义
 32 {
 33     struct TCB* tcbQueue[THREAD_MAXN];//TCB指针数组
 34     int r,f;
 35 };
 36 struct thread_pool//线程池结构体
 37 {
 38     pthread_mutex_t tcb_lock;//互斥锁
 39     int fDestroyed;//线程池是否被销毁
 40     pthread_t *threadid;//存储线程标识符指针
 41     struct TCB *nowRunThread;//指向当前正在运行的线程     
 42     int nFinish;//完成线程数
 43     sem_t sem[THREAD_MAXN];//用于控制线程的信号量
 44     sem_t sem_0_1;//线程0对线程1的控制
 45     struct tcb_queue rrQueue;//轮转队列
 46     struct tcb_queue showQueue;//用于辅助打印的队列
 47     struct TCB *tcb;//存储TCB
 48 };
 49 struct free_block
 50 {
 51     int start;
 52     int size;
 53     struct free_block *next;
 54 };
 55 struct busy_block
 56 {
 57     int id;//编号
 58     int start;
 59     int size;
 60     char *data;//根据需要动态分配
 61     struct busy_blocl *next;
 62 };
 63 struct student
 64 {
 65     char number[9];
 66     char name[21];
 67     int name_size;
 68     int number_stored;
 69     int name_stored;
 70 };
 71 //-----全局变量定义
 72 static struct thread_pool *pool = NULL;//全局变量pool，指向线程池
 73 int nowTime;//当前已走过的时间
 74 int busy_id = -1;
 75 int nFree = 0;
 76 int nBusy = 0;
 77 int stuCnt = 0;
 78 int nameCnt = 0;
 79 int numCnt = 0;
 80 struct free_block *free_queue = NULL;
 81 struct busy_block *busy_queue = NULL;
 82 struct student student_info[STU_NUM];
 83 //-----函数声明
 84 void bubble_sort();//给TCB排序
 85 void show_rr();//打印轮转队列
 86 void show_tcb();//打印所有线程的信息
 87 void pool_init();//初始化线程池
 88 void thread_run_func(void* param);//线程里运行的函数
 89 void round_robin();//时间片轮转算法的调度函数
 90 int pool_destroy();//销毁线程池
 91 void init_free();
 92 struct free_block* create_free(int start, int size, struct free_block *next);
 93 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data);
 94 struct free_block * merge_free(struct free_block *f);
 95 void init_student();
 96 void insert_busy(struct busy_block *pBusy);
 97 void insert_free(struct free_block *pFree);
 98 void delete_free(struct free_block *pFree, struct free_block *pLeft);
 99 void fifo_delete_busy();
100 void lifo_delete_busy();
101 void show_free();
102 void show_busy();
103 void FF_bubble();
104 void BF_bubble();
105 void WF_bubble();
106 void merge_in();
107 void fifo();
108 //main
109 int main()
110 {
111     init_free();
112     printf("---------------------------------1
");
113     init_student();
114     printf("---------------------------------2
");
115     pool_init();
116     printf("---------------------------------3
");
117     printf("打印初始TCB：
");
118     show_tcb();
119     printf("TCB按到达时间排序后：
");
120     bubble_sort();
121     show_tcb();
122     printf("使用时间片轮转算法调度:
");
123     round_robin();
124     sleep(5);//等待所有线程完成
125     pool_destroy();
126     return 0;
127 }
128 //函数定义
129 void bubble_sort()//给TCB排序,按arriveTime升序排列
130 {
131 TCB* ptemp = NULL;
132 for(int i=0; i<THREAD_MAXN; ++i)
133 {
134     ptemp = pool->tcb;
135     while(ptemp && ptemp->next)
136     {
137         if(ptemp->arriveTime > ptemp->next->arriveTime)
138         {//交换两个节点
139             TCB *p_next = ptemp->next->next;
140             TCB *p_pre = ptemp;
141             TCB *p_pre_pre = pool->tcb;
142             if(p_pre_pre == p_pre)
143             {
144                 p_pre_pre = NULL;
145             }
146             else
147             {
148                 while(p_pre_pre && p_pre_pre->next != p_pre)
149                 {
150                     p_pre_pre = p_pre_pre->next;
151                 }
152             }
153             ptemp = ptemp->next;
154             ptemp->next = p_pre;
155             p_pre->next = p_next;
156             if(p_pre_pre)
157             {
158                 p_pre_pre->next = ptemp;
159             }
160             else
161             {
162                 pool->tcb = ptemp;
163             } 
164         }
165         ptemp = ptemp->next;
166     }    
167 }
168 }
169 void show_rr()//打印轮转队列
170 {
171 printf("当前时间为：%d
",nowTime);
172 if(pool->rrQueue.f == pool->rrQueue.r)
173 {
174     printf("目前还没有线程到达
");
175 }
176 else
177 {
178     printf("目前轮转队列为：
");
179 }
180 while(pool->rrQueue.f != pool->rrQueue.r)
181 {
182     pool->showQueue.f = (pool->showQueue.f + 1) % THREAD_MAXN;
183     pool->rrQueue.f = (pool->rrQueue.f + 1) % THREAD_MAXN;
184     pool->showQueue.tcbQueue[pool->showQueue.f] = pool->rrQueue.tcbQueue[pool->rrQueue.f];
185     printf("%d ",pool->rrQueue.tcbQueue[pool->rrQueue.f]->thread_id);
186 }
187 while(pool->showQueue.r != pool->showQueue.f)//将队列放回
188 {
189     pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
190     pool->showQueue.r = (pool->showQueue.r + 1) % THREAD_MAXN;
191     pool->rrQueue.tcbQueue[pool->rrQueue.r] = pool->showQueue.tcbQueue[pool->showQueue.r];
192 }
193 printf("

");
194 }
195 void show_tcb()//打印所有线程的信息
196 {
197 TCB *ptemp = pool->tcb;
198 printf("打印所有线程的信息：
");
199 while(ptemp)
200 {
201     printf("线程%d：到达时间：%d，剩余时间：%d
", ptemp->thread_id, ptemp->arriveTime, ptemp->runTime);
202     ptemp = ptemp->next;
203 }
204 printf("
");
205 }
206 void pool_init()//初始化线程池
207 {
208 pool = (struct thread_pool*)malloc(sizeof(struct thread_pool));
209 pthread_mutex_init(&(pool->tcb_lock), NULL);//初始为未锁住状态
210 pool->fDestroyed = 0;//线程池是否被销毁
211 pool->nFinish = 0;
212 pool->nowRunThread = NULL;//指向当前正在运行的线程 
213 pool->rrQueue.f = pool->rrQueue.r = 0;//轮转队列
214 pool->showQueue.r = pool->showQueue.r = 0;//用于辅助打印的队列
215 pool->tcb = NULL;
216 //创建并初始化TCB
217 TCB* ptemp = pool->tcb;
218 srand(time(0));
219 for(int i=0; i<THREAD_MAXN-1; ++i)
220 {
221     TCB* s = (TCB*)malloc(sizeof(TCB));
222    // s->arriveTime = rand()%9;
223     s->arriveTime = 0;
224     s->runTime = RUN_TIME;
225     s->thread_id = i;//编号令为0
226     s->Finished = false;
227     s->next = NULL;
228     //尾插入
229     if(!pool->tcb)//第一个节点
230     {
231         pool->tcb = s;
232     }
233     else
234     {
235         ptemp = pool->tcb;
236         while(ptemp && ptemp->next)
237         {
238             ptemp = ptemp->next;
239         }
240         ptemp->next = s;
241     }
242 }
243 //初始化信号量
244 ptemp = pool->tcb;
245 int i=0;
246 while(ptemp != NULL)
247 {
248     int i = ptemp->thread_id;
249     sem_init(&(pool->sem[i]), 0, 0);
250     ptemp = ptemp->next;
251 }
252 sem_init(&(pool->sem_0_1), 0, 1);
253 //创建线程
254 ptemp = pool->tcb;
255 pool->threadid = (pthread_t*)malloc(sizeof(pthread_t) * THREAD_MAXN);
256 while(ptemp != NULL)
257 {
258     //把ptemp作为参数传入thread_run_func()
259     int t;
260     t = pthread_create(&(pool->threadid[ptemp->thread_id]), 
261                             NULL, thread_run_func, ptemp);
262     if(!t)//线程创建成功
263     {
264         printf("线程%d创建成功!
", ptemp->thread_id);
265     }
266     else
267     {
268         printf("线程创建失败!
");
269     }
270     ptemp = ptemp->next;
271 }
272 printf("线程池pool初始化完成！
");
273 }
274 void thread_run_func(void *param)//线程里运行的函数
275 {
276 TCB *ptemp = (TCB*)param;
277 // prtinf("线程%d开始了", ptemp->thread_id);
278 while(ptemp->runTime > 0)
279 {
280     printf("线程%d正在等待……
", ptemp->thread_id);
281     sleep(1);
282     sem_wait(&(pool->sem[ptemp->thread_id]));//唤醒
283     printf("线程%d已被唤醒！
",ptemp->thread_id);
284     pthread_mutex_lock(&(pool->tcb_lock));//上互斥锁
285     ptemp->runTime -= RUNTIME_SUB;
286     //线程操作
287     printf("---------------------------------4
");
288     // for(int i=0; i<STU_NUM; ++i)
289     // {
290         int i = numCnt;
291         int j = nameCnt;
292         // if(i==STU_NUM || j==STU_NUM);
293         // {
294         //     if(busy_queue)
295         //     {
296         //         struct busy_block *pBusy = busy_queue;
297         //         while(pBusy)
298         //         {
299         //             printf("data:");
300         //             for(int k=0; k<pBusy->size; ++k)
301         //             {
302         //                 printf("%c", pBusy->data[k]);
303         //             }
304         //             printf("
");
305         //             pBusy = pBusy->next;
306         //         }
307         //     }
308         //     struct TCB *pTCB = pool->tcb;
309         //     while(pTCB)
310         //     {
311         //         pTCB->runTime = 0;
312         //         pTCB = pTCB->next;
313         //     }
314         //     free(pTCB);
315         // }
316         struct free_block *pFree = NULL;
317         struct busy_block *pBusy = NULL;
318         if(ptemp->thread_id == 0)//store number
319         {  
320             printf("想插入：number:");
321             for(int c=0; c<8; ++c)
322             {
323                 printf("%c",student_info[i].number[c]);
324             }
325             printf("
");
326             pFree = free_queue;
327             pBusy = busy_queue;
328             printf("---------------------------------13
");
329             sleep(1);//等待标志被赋值
330             printf("student_info[%d].name_stored = %d
",i-1,student_info[i-1].name_stored);
331 
332                 printf("---------------------------------14
");
333                 int fEnough = 0;
334                 while(!fEnough)
335                 {
336                    if(free_queue)
337                    {
338                         
339                         FF_bubble();
340                         printf("---------------------------------16
");
341                         //BF_bubble();
342                         //WF_bubble();   
343                         printf("紧缩：
");
344                         merge_in();//紧缩
345                    }
346                     //printf("pFree->size:%d
",pFree->size);
347                     show_free();
348                     if(pFree && pFree->size >= 8 )
349                     {
350                         show_free();
351                         printf("---------------------------------18
");
352                         fEnough = 1;
353                         student_info[i].number_stored = 1;
354                         printf("set student_info[%d].number_stored = %d
", i,student_info[i].number_stored);
355                         pBusy = create_busy(pFree->start, 8, NULL, student_info[i].number);
356                         printf("已存储信息：start:%d, size:%d
",pFree->start, pFree->size);
357                         printf("---------------------------------181
");
358                         ++numCnt;
359                         struct free_block *pLeft = create_free(pFree->start+8, pFree->size-8, pFree->next);
360                         delete_free(pFree, pLeft);
361                         show_free();
362                         printf("-----------------插入前--------------182
");
363                         show_busy();
364                         insert_busy(pBusy);
365                         printf("----------------插入后--------------183
");
366                         show_busy();
367                         break;
368                     }
369                     else
370                     {
371                         if(pFree)
372                         {
373                             pFree = pFree->next;
374                         }
375                         else
376                         {
377                             fifo();
378                             //lifo();
379                             pFree = free_queue;
380                         }
381                     }
382                       printf("---------------------------------185
");
383                 }  
384                   printf("---------------------------------186
");
385         }
386         else//store name
387     {  
388             printf("想插入：name:");
389             for(int c=0; c<student_info[j].name_size; ++c)
390             {
391                 printf("%c",student_info[j].name[c]);
392             }
393             printf("
");
394             pFree = free_queue;
395             pBusy = busy_queue;
396             printf("---------------------------------a13
");
397             sleep(1);//等待标志被赋值
398             printf("student_info[%d].number_stored = %d
",j,student_info[j].number_stored);
399            //     if(student_info[i].number_stored)
400              //   {
401                     printf("---------------------------------a14
");
402                     int fEnough = 0;
403                     while(!fEnough)
404                     {
405                         if(free_queue)
406                         {
407                                 FF_bubble();
408                                 printf("---------------------------------16
");
409                                 //BF_bubble();
410                                 //WF_bubble();   
411                                 printf("紧缩：
");
412                                 merge_in();//紧缩
413                         }
414                         show_free();
415                         printf("---------------------------------aa1
");
416                         if(pFree && pFree->size >= student_info[j].name_size )
417                         {   
418                             printf("---------------------------------aa2
");
419                             show_free();
420                             printf("---------------------------------a18
");
421                             fEnough = 1;
422                             ++nameCnt;
423                             student_info[j].number_stored = 1;
424                             printf("set student_info[%d].name_stored = %d
",j,student_info[j].name_stored);
425                             pBusy = create_busy(pFree->start, student_info[j].name_size, NULL, student_info[j].name);
426                             printf("已存储信息：start:%d, size:%d
",pFree->start, pFree->size);
427                             printf("---------------------------------181
");
428                             
429                             struct free_block *pLeft = create_free(pFree->start+student_info[j].name_size,
430                                                         pFree->size-student_info[j].name_size, pFree->next);
431                             delete_free(pFree, pLeft);
432                             show_free();
433                             printf("----------插入前---------------------a182
");
434                             show_busy();
435                             insert_busy(pBusy);
436                             printf("-----------插入后-----------------a183
");
437                             show_busy();
438                             break;
439                         }
440                         else
441                         {
442                             if(pFree)
443                             {
444                                 pFree = pFree->next;
445                             }
446                             else//FIFO
447                             {
448                                 fifo();
449                                 //lifo();
450                                 pFree = free_queue;
451                             }
452                         }
453                         printf("---------------------------------a185, fifo
");
454                         sleep(1);
455                     }  
456                     printf("---------------------------------a186
");
457              //   }
458                printf("---------------------------------a7
");
459     }
460     printf("---------------------------------88
");
461     //线程操作  
462     printf("当前时间为：%d，轮转的线程为线程%d，该线程剩余时间：%d->%d
",
463             nowTime, ptemp->thread_id, ptemp->runTime+RUNTIME_SUB, ptemp->runTime<0?0:ptemp->runTime);
464     sleep(1);
465     if(ptemp->runTime <= 0)//线程已经完成
466     {
467         ++pool->nFinish;
468         ptemp->Finished = true;
469         //出队
470         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
471     }
472     else
473     {//还未完成
474         //出队
475         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
476         //入队
477         pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
478         pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
479     }
480     printf("---------------------------------9
");
481     pthread_mutex_unlock(&(pool->tcb_lock));
482     sleep(1);
483 }
484 pthread_exit(NULL);
485 }
486 void round_robin()//时间片轮转算法的调度函数
487 {
488     TCB *ptemp = pool->tcb;
489     while(1)
490     {
491         sleep(1);
492         pthread_mutex_lock(&(pool->tcb_lock));
493         if(pool->nFinish == THREAD_MAXN-1)//所有线程完成
494             break;
495         while(ptemp && ptemp->arriveTime == nowTime)
496         {
497             printf("当前时间为：%d，线程%d进入轮转队列，运行时间：%d
", 
498             nowTime, ptemp->thread_id, ptemp->runTime);
499             pool->rrQueue.r = (pool->rrQueue.r+1)%THREAD_MAXN;
500             pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
501             ptemp = ptemp->next;
502         }
503         if(pool->rrQueue.f != pool->rrQueue.r)
504         {
505             pool->nowRunThread = pool->rrQueue.tcbQueue[(pool->rrQueue.f+1)%THREAD_MAXN];
506             printf("准备唤醒线程%d
",pool->nowRunThread->thread_id);
507             sleep(1);
508             sem_post(&(pool->sem[pool->nowRunThread->thread_id]));
509         }
510         show_rr();
511         ++nowTime;
512         pthread_mutex_unlock(&(pool->tcb_lock));
513         sleep(1);
514     }
515 }
516 int pool_destroy()//销毁线程池
517 {
518     if(pool->fDestroyed)//防止重复销毁
519         return -1;
520     pool->fDestroyed = 1;
521     TCB* ptemp = pool->tcb;
522     while(ptemp)
523     {
524         pthread_join(pool->threadid[ptemp->thread_id], NULL);
525         printf("线程%d已结束
",ptemp->thread_id);
526         ptemp = ptemp->next;
527     }
528     free(ptemp);
529     free(pool->threadid);
530     pthread_mutex_destroy(&(pool->tcb_lock));
531     free(pool);
532     pool = NULL;
533     printf("线程池pool已被销毁！
");
534 }
535 
536 //----------------------------------------------------------------------------------
537 
538 void init_free()
539 {
540     int start_address = 0;
541     struct free_block *ptemp = NULL;
542     for(int i=0; i<INIT_FREE_BLOCK_NUM; ++i)
543     {
544         struct free_block* s = create_free(start_address, INIT_FREE_BLOCK_SIZE, NULL);
545     printf("------------create_free------%d, %d
", s->start, s->size);
546         ++nFree;
547         if(free_queue == NULL)
548         {
549             free_queue = s;
550             printf("---------------------------------10
");
551         }
552         else
553         {
554             ptemp = free_queue;
555             printf("---------------------------------11
");
556             while(ptemp && ptemp->next)
557             {
558                 ptemp = ptemp->next;
559             }
560             ptemp->next = s;
561         }
562         start_address += INIT_FREE_BLOCK_SIZE;
563     }
564     printf("空闲内存块初始化完成！
");
565     show_free();
566 }
567 struct free_block* create_free(int start, int size, struct free_block *next)
568 {
569     struct free_block *s = (struct free_block*)malloc(sizeof(struct free_block));
570     s->start = start;
571     s->size = size;
572     s->next = next;
573     return s;
574 }
575 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data)
576 {
577     struct busy_block *s = (struct busy_block*)malloc(sizeof(struct busy_block));
578     s->start = start;
579     s->id = ++busy_id;
580     s->next = NULL;
581     s->size = size;
582     s->data = (char*)malloc(sizeof(char) * size);
583     for(int i=0; i<size; ++i)
584     {
585         s->data[i] = data[i];
586     }   
587     ++nBusy;
588     return s;
589 }
590 
591 void init_student()
592 {
593     srand(time(0));
594     for(int i=0; i<STU_NUM; ++i)
595     {
596         strcpy(student_info[i].number, "201820");
597         if(i < 10)
598         {
599             student_info[i].number[6] = '0';
600             student_info[i].number[7] = '0' + i;
601         }
602         else
603         {
604             student_info[i].number[6] = '0' + i/10;
605             student_info[i].number[7] = '0' + i%10;
606         }
607         student_info[i].number[8] = '';
608         int n = 4;
609            int ran = rand()%20;
610         printf("rand : %d
",ran);
611         printf("n : %d
", n);
612         student_info[i].name_size = n+ran;
613         for(int j=0; j<n; ++j)
614         {
615             student_info[i].name[j] = (char)('a' + i);
616         }
617         student_info[i].name[n+ran] = '';
618         student_info[i].name_stored = 0;
619         student_info[i].number_stored = 0;
620 
621         printf("student:%d %s, %d, %s
", i,student_info[i].name, student_info[i].name_size, student_info[i].number);
622     }
623     printf("学生信息初始化完成！
");
624 }
625 
626 void FF_bubble()
627 {
628     struct free_block* ptemp = NULL;
629     if(free_queue!=NULL)
630     for(int i=0; i<FREE_MAXN; ++i)
631     {
632         ptemp = free_queue; 
633         while(ptemp && ptemp->next)
634         {
635             if(ptemp->start > ptemp->next->start )
636             {//交换两个节点
637                 struct free_block *p_next = ptemp->next->next;
638                 struct free_block *p_pre = ptemp;
639                 struct free_block *p_pre_pre = free_queue;
640                 if(p_pre_pre == p_pre)
641                 {
642                     p_pre_pre = NULL;
643                 }
644                 else
645                 {
646                     while(p_pre_pre && p_pre_pre->next != p_pre)
647                     {
648                         p_pre_pre = p_pre_pre->next;
649                     }
650                 }
651                 ptemp = ptemp->next;
652                 ptemp->next = p_pre;
653                 p_pre->next = p_next;
654                 if(p_pre_pre)
655                 {
656                     p_pre_pre->next = ptemp;
657                 }
658                 else
659                 {
660                     free_queue = ptemp;
661                 } 
662             }
663             ptemp = ptemp->next;
664         }    
665     }
666 }
667 
668 void BF_bubble()
669 {
670     struct free_block* ptemp = NULL;
671     if(free_queue!=NULL)
672     for(int i=0; i<FREE_MAXN; ++i)
673     {
674         ptemp = free_queue; 
675         while(ptemp && ptemp->next)
676         {
677             if(ptemp->size > ptemp->next->size )
678             {//交换两个节点
679                 struct free_block *p_next = ptemp->next->next;
680                 struct free_block *p_pre = ptemp;
681                 struct free_block *p_pre_pre = free_queue;
682                 if(p_pre_pre == p_pre)
683                 {
684                     p_pre_pre = NULL;
685                 }
686                 else
687                 {
688                     while(p_pre_pre && p_pre_pre->next != p_pre)
689                     {
690                         p_pre_pre = p_pre_pre->next;
691                     }
692                 }
693                 ptemp = ptemp->next;
694                 ptemp->next = p_pre;
695                 p_pre->next = p_next;
696                 if(p_pre_pre)
697                 {
698                     p_pre_pre->next = ptemp;
699                 }
700                 else
701                 {
702                     free_queue = ptemp;
703                 } 
704             }
705             ptemp = ptemp->next;
706         }    
707     }
708 }
709 
710 void WF_bubble()
711 {
712     struct free_block* ptemp = NULL;
713     if(free_queue!=NULL)
714     for(int i=0; i<FREE_MAXN; ++i)
715     {
716         ptemp = free_queue; 
717         while(ptemp && ptemp->next)
718         {
719             if(ptemp->size < ptemp->next->size )
720             {//交换两个节点
721                 struct free_block *p_next = ptemp->next->next;
722                 struct free_block *p_pre = ptemp;
723                 struct free_block *p_pre_pre = free_queue;
724                 if(p_pre_pre == p_pre)
725                 {
726                     p_pre_pre = NULL;
727                 }
728                 else
729                 {
730                     while(p_pre_pre && p_pre_pre->next != p_pre)
731                     {
732                         p_pre_pre = p_pre_pre->next;
733                     }
734                 }
735                 ptemp = ptemp->next;
736                 ptemp->next = p_pre;
737                 p_pre->next = p_next;
738                 if(p_pre_pre)
739                 {
740                     p_pre_pre->next = ptemp;
741                 }
742                 else
743                 {
744                     free_queue = ptemp;
745                 } 
746             }
747             ptemp = ptemp->next;
748         }    
749     }
750 }
751 
752 void insert_busy(struct busy_block *pBusy)
753 {
754     if(busy_queue == NULL) 
755     {
756         busy_queue = pBusy;
757     }
758     else
759     {
760         struct busy_block *ptemp = busy_queue;
761         printf("--------busy insert1
");
762         while(ptemp && ptemp->next)
763         {
764              printf("--------busy insert2
");
765             ptemp = ptemp->next;
766         }
767          printf("--------busy insert3
");
768         ptemp->next = pBusy;
769     }
770 }
771 
772 void insert_free(struct free_block *pFree)
773 {
774     if(free_queue == NULL)
775     {
776         free_queue = pFree;
777     }
778     else
779     {
780         struct free_block *ptemp = free_queue;
781         while(ptemp && ptemp->next)
782         {
783             ptemp = ptemp->next;
784         }
785         ptemp->next = pFree;
786     }
787     
788 
789 }
790 
791 void delete_free(struct free_block *pFree, struct free_block *pLeft)
792 {
793     struct free_block *ptemp = free_queue;
794     struct free_block *pre = NULL;
795     if(ptemp == NULL)return;
796     
797     while(ptemp)
798     {
799         if(ptemp == pFree)
800         {
801             break;
802         }
803         pre = ptemp;
804         ptemp = ptemp->next;
805     }
806     if(pre)
807     {
808         if(pLeft->size == 0)
809         {
810             pre->next = ptemp->next;
811             free(pLeft);
812         }
813         else
814         {
815             pre->next = pLeft;
816         }
817         free(ptemp);
818     }
819     else
820     {
821         if(pLeft->size == 0)
822         {
823             free_queue = ptemp->next;
824             free(pLeft);
825         }       
826         else
827             free_queue = pLeft;
828 
829             free(ptemp);
830     }
831 }
832 
833 void fifo_delete_busy()
834 {
835     if(busy_queue)
836     {
837         struct busy_block *ptemp = busy_queue;
838         busy_queue = busy_queue->next;
839         free(ptemp);
840     }
841     else
842     {
843         printf("busy空
");
844     }
845 }
846 void lifo_delete_busy()
847 {
848     if(busy_queue)
849     {
850         struct busy_block *ptemp = busy_queue;
851         struct busy_block *pre = NULL;
852         while(ptemp && ptemp->next)
853         {
854             pre = ptemp;
855             ptemp = ptemp->next;
856         }
857         if(pre == NULL)
858         {
859             busy_queue = NULL;
860         }
861         else
862         {
863             pre->next = NULL;
864         }
865         free(ptemp);
866         ptemp = NULL;
867     }
868     else
869     {
870         printf("busy空
");
871     }
872 }
873 void show_free()
874 {
875     printf("show free
");
876     if(free_queue)
877     {
878         struct free_block *ptemp = free_queue;
879         printf("显示空闲块：
");
880         while(ptemp != NULL)
881         {
882             printf("开始：%d，大小：%d
",ptemp->start, ptemp->size);
883             ptemp = ptemp->next;
884         }
885         printf("
");
886     }
887     else
888     {
889         printf("free is empty
");
890     }
891     
892 }
893 
894 void show_busy()
895 {
896     printf("show busy
");
897     if(busy_queue != NULL)
898     {
899         struct busy_block *ptemp = busy_queue;
900         printf("显示已分配块：
");
901         while(ptemp != NULL)
902         {
903              printf("--------show busy1
");
904             printf("id:%d，开始：%d，大小：%d
",ptemp->id, ptemp->start, ptemp->size);
905             ptemp = ptemp->next;
906             printf("--------show busy2
");
907         }    
908         printf("--------show busy3
");
909         printf("
");
910     }
911     else
912     {
913         printf("busy 空了
");
914     }
915 }
916 
917 void merge_in()
918 {
919     free_queue = merge_free(free_queue);
920     printf("缩完
");
921 }
922 
923 struct free_block * merge_free(struct free_block *f)
924 {
925     if(f && f->next)
926     {
927         f->next = merge_free(f->next);
928         if(f->next && (f->start + f->size == f->next->start))
929         {
930             struct free_block *p = f->next;
931             f->next = p->next;
932             f->size += p->size;
933             free(p);
934             p=NULL;
935         }
936     }
937     return f;
938 }
939 
940 void fifo()
941 {
942     if(busy_queue)
943     {
944         printf("---------------------------------afifo
");
945         printf("啊这
");
946         printf("调出1
");
947         printf("被调出的信息:start=%d，size=%d, info:", busy_queue->start, busy_queue->size);
948         for(int k=0; k<busy_queue->size; ++k)
949         {
950             printf("%c",busy_queue->data[k]);
951         }
952         printf("
");
953         struct free_block *pFree = create_free(busy_queue->start, busy_queue->size, NULL);
954         printf("插入free
");
955         insert_free(pFree);
956         show_busy();
957         printf("调出2
");
958         show_free();
959         fifo_delete_busy();
960     }
961     else
962     {
963         printf("busy 已空，无法再调出
");
964     }
965 }
966 
967 void lifo()
968 {
969     if(busy_queue)
970     {
971         struct busy_block *pBusy = busy_queue;
972         while(pBusy && pBusy->next)
973         {
974             pBusy = pBusy->next;
975         }
976         printf("---------------------------------alifo
");
977         printf("啊这
");
978         printf("调出1
");
979         printf("被调出的信息:start=%d，size=%d, info:", pBusy->start, pBusy->size);
980         for(int k=0; k<pBusy->size; ++k)
981         {
982             printf("%c",pBusy->data[k]);
983         }
984         printf("
");
985         struct free_block *pFree = create_free(pBusy->start, pBusy->size, NULL);
986         printf("插入free
");
987         insert_free(pFree);
988         show_busy();
989         printf("调出2
");
990         show_free();
991         lifo_delete_busy();
992     }
993     else
994     {
995         printf("busy 已空，无法再调出
");
996     }
997 }

初版次品

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <string.h>
  4 #include <semaphore.h>
  5 #include <unistd.h>
  6 #include <time.h>
  7 #include <sys/types.h>
  8 #include <pthread.h>
  9 #define bool int
 10 #define true 1
 11 #define false 0
 12 #define THREAD_MAXN 3//线程数
 13 #define RUNTIME_SUB 1//每次运行线程减去的运行时间
 14 #define RUN_TIME 100//线程运行时间
 15 #define INIT_FREE_BLOCK_NUM 8//内存块初始数量
 16 #define INIT_FREE_BLOCK_SIZE 10//内存块初始大小
 17 #define FREE_MAXN 100//最大空闲块数量
 18 #define STU_NUM 50//学生数量
 19 //-----结构体定义
 20 typedef struct TCB//存储线程信息
 21 {
 22     int thread_id;//线程编号
 23     int arriveTime;//线程到达时间
 24     int runTime;//持续时间
 25     int finishTime;//完成时间
 26     int wholeTime;//周转时间
 27     double weightWholeTime;//带权周转时间
 28     bool Finished;//线程是否完成
 29     struct TCB* next;//使用链式存储方式
 30 }TCB;
 31 struct tcb_queue//TCB队列定义
 32 {
 33     struct TCB* tcbQueue[THREAD_MAXN];//TCB指针数组
 34     int r,f;
 35 };
 36 struct thread_pool//线程池结构体
 37 {
 38     pthread_mutex_t tcb_lock;//互斥锁
 39     int fDestroyed;//线程池是否被销毁
 40     pthread_t *threadid;//存储线程标识符指针
 41     struct TCB *nowRunThread;//指向当前正在运行的线程     
 42     int nFinish;//完成线程数
 43     sem_t sem[THREAD_MAXN];//用于控制线程的信号量
 44     sem_t sem_0_1;//线程0对线程1的控制
 45     struct tcb_queue rrQueue;//轮转队列
 46     struct tcb_queue showQueue;//用于辅助打印的队列
 47     struct TCB *tcb;//存储TCB
 48 };
 49 struct free_block//空闲块结构体
 50 {
 51     int start;//起始位置
 52     int size;
 53     struct free_block *next;
 54 };
 55 struct busy_block//被分配的内存块
 56 {
 57     int id;//编号
 58     int start;
 59     int size;
 60     char *data;//根据需要动态分配
 61     struct busy_blocl *next;
 62 };
 63 struct student//储存学生信息
 64 {
 65     char number[9];
 66     char name[41];
 67     int name_size;
 68 };
 69 //-----全局变量定义
 70 static struct thread_pool *pool = NULL;//全局变量pool，指向线程池
 71 int nowTime;//当前已走过的时间
 72 int busy_cnt = -1;//分配块编号计数器
 73 int nFree = 0;//空闲块数量
 74 int nBusy = 0;//已分配块数量
 75 int nameCnt = 0;//名字存储计数器
 76 int numCnt = 0;//学号存储计数器
 77 int ScheduleCnt = 0;//调度次数
 78 struct free_block *free_queue = NULL;//储存空闲块的链表
 79 struct busy_block *busy_queue = NULL;//储存已分配块的链表
 80 struct student student_info[STU_NUM];
 81 //-----函数声明
 82 void TCB_bubble();//给TCB排序
 83 void show_rr();//打印轮转队列
 84 void show_tcb();//打印所有线程的信息
 85 void pool_init();//初始化线程池
 86 void thread_run_func(void* param);//线程里运行的函数
 87 void round_robin();//时间片轮转算法的调度函数
 88 int pool_destroy();//销毁线程池
 89 void init_free();//初始化空闲块
 90 struct free_block* create_free(int start, int size, struct free_block *next);//创建一个空闲块
 91 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data);//创建一个已分配块
 92 struct free_block * merge_free(struct free_block *f);//合并所有能够合并的空闲内存块
 93 void init_student();//初始化学生的学号，姓名，采用随机生成的方法
 94 void insert_busy(struct busy_block *pBusy);//尾插法插入一个分配块到链表busy_queue中
 95 void insert_free(struct free_block *pFree);//尾插法插入一个空闲块到链表free_queue中
 96 void delete_free(struct free_block *pFree, struct free_block *pLeft);//删除一个空闲块中被占用的部分，保留剩余部分
 97 void fifo_delete_busy();//fifo算法中删除分配块
 98 void lifo_delete_busy();//lifo算法中删除分配块
 99 void show_free();//显示空闲块链表   
100 void show_busy();//显示分配块链表
101 void FF_bubble();//按照start升序，对空闲块冒泡排序
102 void BF_bubble();//按照size升序，对空闲块冒泡排序
103 void WF_bubble();//按照size降序，对空闲块冒泡排序  
104 void merge_in();//合并空闲内存块函数的入口
105 void fifo();//fifo算法调出分配块
106 void lifo();//lifo算法调出分配块
107 //main
108 int main()
109 {  
110     init_student();
111     init_free();
112     pool_init();
113     TCB_bubble();
114     show_tcb();
115     round_robin();
116     sleep(5);//等待所有线程完成
117     pool_destroy();
118     return 0;
119 }
120 //函数定义
121 void TCB_bubble()//给TCB排序,按arriveTime升序排列
122 {
123 TCB* ptemp = NULL;
124 for(int i=0; i<THREAD_MAXN; ++i)
125 {
126     ptemp = pool->tcb;
127     while(ptemp && ptemp->next)
128     {
129         if(ptemp->arriveTime > ptemp->next->arriveTime)
130         {//交换两个节点
131             TCB *p_next = ptemp->next->next;
132             TCB *p_pre = ptemp;//后面ptemp = ptemp->next，当前ptemp相当于pre
133             TCB *p_pre_pre = pool->tcb;//pre的pre
134             if(p_pre_pre == p_pre)//说明ptemp是头结点
135             {
136                 p_pre_pre = NULL;
137             }
138             else//否则找到pre_pre所在位置
139             {
140                 while(p_pre_pre && p_pre_pre->next != p_pre)
141                 {
142                     p_pre_pre = p_pre_pre->next;
143                 }
144             }
145             //交换结点
146             ptemp = ptemp->next;
147             ptemp->next = p_pre;
148             p_pre->next = p_next;
149             if(p_pre_pre)
150             {
151                 p_pre_pre->next = ptemp;
152             }
153             else
154             {
155                 pool->tcb = ptemp;
156             } 
157         }
158         ptemp = ptemp->next;
159     }    
160 }
161 }
162 void show_rr()//打印轮转队列
163 {
164 printf("当前时间为：%d
",nowTime);
165 if(pool->rrQueue.f == pool->rrQueue.r)
166 {
167     printf("目前还没有线程到达
");
168 }
169 else
170 {
171     printf("目前轮转队列为：
");
172 }
173 while(pool->rrQueue.f != pool->rrQueue.r)
174 {
175     pool->showQueue.f = (pool->showQueue.f + 1) % THREAD_MAXN;
176     pool->rrQueue.f = (pool->rrQueue.f + 1) % THREAD_MAXN;
177     pool->showQueue.tcbQueue[pool->showQueue.f] = pool->rrQueue.tcbQueue[pool->rrQueue.f];
178     printf("%d ",pool->rrQueue.tcbQueue[pool->rrQueue.f]->thread_id);
179 }
180 while(pool->showQueue.r != pool->showQueue.f)//将队列放回
181 {
182     pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
183     pool->showQueue.r = (pool->showQueue.r + 1) % THREAD_MAXN;
184     pool->rrQueue.tcbQueue[pool->rrQueue.r] = pool->showQueue.tcbQueue[pool->showQueue.r];
185 }
186 printf("

");
187 }
188 void show_tcb()//打印所有线程的信息
189 {
190 TCB *ptemp = pool->tcb;
191 printf("打印所有线程的信息：
");
192 while(ptemp)
193 {
194     printf("线程%d：到达时间：%d，剩余时间：%d
", ptemp->thread_id, ptemp->arriveTime, ptemp->runTime);
195     ptemp = ptemp->next;
196 }
197 printf("
");
198 }
199 void pool_init()//初始化线程池
200 {
201 pool = (struct thread_pool*)malloc(sizeof(struct thread_pool));
202 pthread_mutex_init(&(pool->tcb_lock), NULL);//初始为未锁住状态
203 pool->fDestroyed = 0;//线程池是否被销毁
204 pool->nFinish = 0;
205 pool->nowRunThread = NULL;//指向当前正在运行的线程 
206 pool->rrQueue.f = pool->rrQueue.r = 0;//轮转队列
207 pool->showQueue.r = pool->showQueue.r = 0;//用于辅助打印的队列
208 pool->tcb = NULL;
209 //创建并初始化TCB
210 TCB* ptemp = pool->tcb;
211 srand(time(0));
212 for(int i=0; i<THREAD_MAXN-1; ++i)
213 {
214     TCB* s = (TCB*)malloc(sizeof(TCB));
215    // s->arriveTime = rand()%9;
216     s->arriveTime = 0;
217     s->runTime = RUN_TIME;
218     s->thread_id = i;//编号令为0
219     s->Finished = false;
220     s->next = NULL;
221     //尾插入
222     if(!pool->tcb)//第一个节点
223     {
224         pool->tcb = s;
225     }
226     else
227     {
228         ptemp = pool->tcb;
229         while(ptemp && ptemp->next)
230         {
231             ptemp = ptemp->next;
232         }
233         ptemp->next = s;
234     }
235 }
236 //初始化信号量
237 ptemp = pool->tcb;
238 int i=0;
239 while(ptemp)
240 {
241     int i = ptemp->thread_id;
242     sem_init(&(pool->sem[i]), 0, 0);
243     ptemp = ptemp->next;
244 }
245 sem_init(&(pool->sem_0_1), 0, 1);
246 //创建线程
247 ptemp = pool->tcb;
248 pool->threadid = (pthread_t*)malloc(sizeof(pthread_t) * THREAD_MAXN);
249 while(ptemp)
250 {
251     //把ptemp作为参数传入thread_run_func()
252     int t;
253     t = pthread_create(&(pool->threadid[ptemp->thread_id]), 
254                             NULL, thread_run_func, ptemp);
255     if(!t)//线程创建成功
256     {
257         printf("线程%d创建成功!
", ptemp->thread_id);
258     }
259     else
260     {
261         printf("线程创建失败!
");
262     }
263     ptemp = ptemp->next;
264 }
265 printf("线程池pool初始化完成！
");
266 }
267 void thread_run_func(void *param)//线程里运行的函数
268 {
269     TCB *ptemp = (TCB*)param;
270     while(ptemp->runTime > 0)
271     {
272         //printf("线程%d正在等待……
", ptemp->thread_id);
273         sleep(1);
274         sem_wait(&(pool->sem[ptemp->thread_id]));//唤醒
275         //printf("线程%d已被唤醒！
",ptemp->thread_id);
276         pthread_mutex_lock(&(pool->tcb_lock));//上互斥锁
277         ptemp->runTime -= RUNTIME_SUB;
278         //线程操作
279             int i = numCnt;
280             int j = nameCnt;
281             struct free_block *pFree = NULL;
282             struct busy_block *pBusy = NULL;
283             if(ptemp->thread_id == 0)//store number
284             {  
285                 printf("将要放入内存的信息：");
286                 for(int c=0; c<8; ++c)
287                 {
288                     printf("%c",student_info[i].number[c]);
289                 }
290                 printf("，大小：8
");
291                 pFree = free_queue;
292                 pBusy = busy_queue;
293                     int fEnough = 0;//内存大小是否足够
294                     while(!fEnough)
295                     {
296                     if(free_queue)
297                     {
298                             //FF_bubble();
299                             BF_bubble();
300                             //WF_bubble();   
301                             printf("将所有空闲内存块紧缩
");
302                             merge_in();//紧缩
303                             show_free();
304                     }
305                         if(pFree && pFree->size >= 8 )
306                         {
307                             fEnough = 1;
308                             pBusy = create_busy(pFree->start, 8, NULL, student_info[i].number);
309                             printf("正在存储的信息：开始地址:%d, 大小:8
",pFree->start);
310                             ++numCnt;
311                             struct free_block *pLeft = create_free(pFree->start+8, pFree->size-8, pFree->next);
312                             delete_free(pFree, pLeft);
313                             insert_busy(pBusy);
314                             show_busy();
315                             break;
316                         }
317                         else
318                         {
319                             if(pFree)
320                             {
321                                 printf("当前指向空闲内存大小不够，跳到下一块空闲内存
");
322                                 pFree = pFree->next;
323                             }
324                             else
325                             {
326                                 printf("没有足够大小的空闲内存可用，开始调度：
");
327                                 fifo();
328                                 //lifo();
329                                 pFree = free_queue;
330                             }
331                         }
332                     }  
333             }
334         else//store name
335         {  
336             printf("将要放入内存的信息：");
337             for(int c=0; c<student_info[i].name_size; ++c)
338             {
339                 printf("%c",student_info[i].name[c]);
340             }
341             printf("，大小：%d",student_info[i].name_size);
342             pFree = free_queue;
343             pBusy = busy_queue;
344                     int fEnough = 0;
345                     while(!fEnough)
346                     {
347                         if(free_queue)
348                         {
349                             //FF_bubble();
350                             BF_bubble();
351                             //WF_bubble();   
352                             printf("将所有空闲内存块紧缩
");
353                             merge_in();//紧缩
354                             show_free();
355                         }
356                         if(pFree && pFree->size >= student_info[j].name_size )
357                         {   
358                             fEnough = 1;
359                             ++nameCnt;
360                             pBusy = create_busy(pFree->start, student_info[j].name_size, NULL, student_info[j].name);
361                            printf("正在存储的信息：开始地址:%d, 大小:%d
", pFree->start, student_info[j].name_size);
362                             struct free_block *pLeft = create_free(pFree->start+student_info[j].name_size,
363                                                         pFree->size-student_info[j].name_size, pFree->next);
364                             delete_free(pFree, pLeft);
365                             insert_busy(pBusy);
366                             show_busy();
367                             break;
368                         }
369                         else
370                         {
371                             if(pFree)
372                             {
373                                 printf("当前指向空闲内存大小不够，跳到下一块空闲内存
");
374                                 pFree = pFree->next;
375                             }
376                             else//FIFO
377                             {
378                                 printf("没有足够大小的空闲内存可用，开始调度：
");
379                                 fifo();
380                                 //lifo();
381                                 pFree = free_queue;
382                             }
383                         }
384                     }  
385                 }
386         
387     //线程操作  
388     //printf("当前时间为：%d，轮转的线程为线程%d，该线程剩余时间：%d->%d
",
389             nowTime, ptemp->thread_id, ptemp->runTime+RUNTIME_SUB, ptemp->runTime<0?0:ptemp->runTime);
390     //sleep(1);
391     if(ptemp->runTime <= 0)//线程已经完成
392     {
393         ++pool->nFinish;
394         ptemp->Finished = true;
395         //出队
396         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
397     }
398     else
399     {//还未完成
400         //出队
401         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
402         //入队
403         pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
404         pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
405     }
406     pthread_mutex_unlock(&(pool->tcb_lock));
407     sleep(1);
408 }
409     pthread_exit(NULL);
410 }
411 void round_robin()//时间片轮转算法的调度函数
412 {
413     TCB *ptemp = pool->tcb;
414     while(1)
415     {
416         sleep(1);
417         pthread_mutex_lock(&(pool->tcb_lock));
418         if(pool->nFinish == THREAD_MAXN-1)//所有线程完成
419             break;
420         while(ptemp && ptemp->arriveTime == nowTime)
421         {
422             //printf("当前时间为：%d，线程%d进入轮转队列，运行时间：%d
", 
423             nowTime, ptemp->thread_id, ptemp->runTime);
424             pool->rrQueue.r = (pool->rrQueue.r+1)%THREAD_MAXN;
425             pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
426             ptemp = ptemp->next;
427         }
428         if(pool->rrQueue.f != pool->rrQueue.r)
429         {
430             pool->nowRunThread = pool->rrQueue.tcbQueue[(pool->rrQueue.f+1)%THREAD_MAXN];
431             //printf("准备唤醒线程%d
",pool->nowRunThread->thread_id);
432             sleep(1);
433             sem_post(&(pool->sem[pool->nowRunThread->thread_id]));
434         }
435         //show_rr();
436         ++nowTime;
437         pthread_mutex_unlock(&(pool->tcb_lock));
438         sleep(1);
439     }
440 }
441 int pool_destroy()//销毁线程池
442 {
443     if(pool->fDestroyed)//防止重复销毁
444         return -1;
445     pool->fDestroyed = 1;
446     TCB* ptemp = pool->tcb;
447     while(ptemp)
448     {
449         pthread_join(pool->threadid[ptemp->thread_id], NULL);
450         printf("线程%d已结束
",ptemp->thread_id);
451         ptemp = ptemp->next;
452     }
453     free(ptemp);
454     free(pool->threadid);
455     pthread_mutex_destroy(&(pool->tcb_lock));
456     free(pool);
457     pool = NULL;
458     printf("线程池pool已被销毁！
");
459 }
460 
461 //----------------------------------------------------------------------------------
462 
463 void init_free()
464 {
465     int start_address = 0;
466     struct free_block *ptemp = NULL;
467     for(int i=0; i<INIT_FREE_BLOCK_NUM; ++i)
468     {
469         struct free_block* s = create_free(start_address, INIT_FREE_BLOCK_SIZE, NULL);
470         printf("已创建起始地址为%d，大小为%d的空闲块！
", s->start, s->size);
471         ++nFree;
472         if(!free_queue)
473         {
474             free_queue = s;
475         }
476         else
477         {
478             ptemp = free_queue;
479             while(ptemp && ptemp->next)
480             {
481                 ptemp = ptemp->next;
482             }
483             ptemp->next = s;
484         }
485         start_address += INIT_FREE_BLOCK_SIZE;
486     }
487     printf("空闲内存块初始化完成！
");
488     show_free();
489 }
490 struct free_block* create_free(int start, int size, struct free_block *next)
491 {
492     struct free_block *s = (struct free_block*)malloc(sizeof(struct free_block));
493     s->start = start;
494     s->size = size;
495     s->next = next;
496     return s;
497 }
498 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data)
499 {
500     struct busy_block *s = (struct busy_block*)malloc(sizeof(struct busy_block));
501     s->start = start;
502     s->id = ++busy_cnt;
503     s->next = NULL;
504     s->size = size;
505     s->data = (char*)malloc(sizeof(char) * size);
506     for(int i=0; i<size; ++i)
507     {
508         s->data[i] = data[i];
509     }   
510     return s;
511 }
512 void init_student()
513 {
514     srand(time(0));
515     for(int i=0; i<STU_NUM; ++i)
516     {
517         strcpy(student_info[i].number, "201820");
518         if(i < 10)
519         {
520             student_info[i].number[6] = '0';
521             student_info[i].number[7] = '0' + i;
522         }
523         else
524         {
525             student_info[i].number[6] = '0' + i/10;
526             student_info[i].number[7] = '0' + i%10;
527         }
528         student_info[i].number[8] = '';
529            int ran = rand()%37;
530         student_info[i].name_size = 4+ran;//拼音长度：4~40
531         for(int j=0; j<student_info[i].name_size; ++j)
532         {
533             if(i < 26)
534             {
535                 student_info[i].name[j] = (char)('a' + i);
536             }
537             else
538             {
539                 student_info[i].name[j] = (char)('A' + i - 26);
540             }
541         }
542         student_info[i].name[4+ran] = '';
543         printf("编号：%d，姓名：%s，姓名大小：%d，学号：%s
", i, student_info[i].name, student_info[i].name_size, student_info[i].number);
544     }
545     printf("学生信息初始化完成！
");
546 }
547 void FF_bubble()
548 {
549     struct free_block* ptemp = NULL;
550     if(free_queue!=NULL)
551     for(int i=0; i<FREE_MAXN; ++i)
552     {
553         ptemp = free_queue; 
554         while(ptemp && ptemp->next)
555         {
556             if(ptemp->start > ptemp->next->start )
557             {//交换两个节点
558                 struct free_block *p_next = ptemp->next->next;
559                 struct free_block *p_pre = ptemp;
560                 struct free_block *p_pre_pre = free_queue;
561                 if(p_pre_pre == p_pre)
562                 {
563                     p_pre_pre = NULL;
564                 }
565                 else
566                 {
567                     while(p_pre_pre && p_pre_pre->next != p_pre)
568                     {
569                         p_pre_pre = p_pre_pre->next;
570                     }
571                 }
572                 ptemp = ptemp->next;
573                 ptemp->next = p_pre;
574                 p_pre->next = p_next;
575                 if(p_pre_pre)
576                 {
577                     p_pre_pre->next = ptemp;
578                 }
579                 else
580                 {
581                     free_queue = ptemp;
582                 } 
583             }
584             ptemp = ptemp->next;
585         }    
586     }
587 }
588 void BF_bubble()
589 {
590     struct free_block* ptemp = NULL;
591     if(free_queue!=NULL)
592     for(int i=0; i<FREE_MAXN; ++i)
593     {
594         ptemp = free_queue; 
595         while(ptemp && ptemp->next)
596         {
597             if(ptemp->size > ptemp->next->size )
598             {//交换两个节点
599                 struct free_block *p_next = ptemp->next->next;
600                 struct free_block *p_pre = ptemp;
601                 struct free_block *p_pre_pre = free_queue;
602                 if(p_pre_pre == p_pre)
603                 {
604                     p_pre_pre = NULL;
605                 }
606                 else
607                 {
608                     while(p_pre_pre && p_pre_pre->next != p_pre)
609                     {
610                         p_pre_pre = p_pre_pre->next;
611                     }
612                 }
613                 ptemp = ptemp->next;
614                 ptemp->next = p_pre;
615                 p_pre->next = p_next;
616                 if(p_pre_pre)
617                 {
618                     p_pre_pre->next = ptemp;
619                 }
620                 else
621                 {
622                     free_queue = ptemp;
623                 } 
624             }
625             ptemp = ptemp->next;
626         }    
627     }
628 }
629 
630 void WF_bubble()
631 {
632     struct free_block* ptemp = NULL;
633     if(free_queue!=NULL)
634     for(int i=0; i<FREE_MAXN; ++i)
635     {
636         ptemp = free_queue; 
637         while(ptemp && ptemp->next)
638         {
639             if(ptemp->size < ptemp->next->size )
640             {//交换两个节点
641                 struct free_block *p_next = ptemp->next->next;
642                 struct free_block *p_pre = ptemp;
643                 struct free_block *p_pre_pre = free_queue;
644                 if(p_pre_pre == p_pre)
645                 {
646                     p_pre_pre = NULL;
647                 }
648                 else
649                 {
650                     while(p_pre_pre && p_pre_pre->next != p_pre)
651                     {
652                         p_pre_pre = p_pre_pre->next;
653                     }
654                 }
655                 ptemp = ptemp->next;
656                 ptemp->next = p_pre;
657                 p_pre->next = p_next;
658                 if(p_pre_pre)
659                 {
660                     p_pre_pre->next = ptemp;
661                 }
662                 else
663                 {
664                     free_queue = ptemp;
665                 } 
666             }
667             ptemp = ptemp->next;
668         }    
669     }
670 }
671 
672 void insert_busy(struct busy_block *pBusy)
673 {
674     if(!busy_queue) 
675     {
676         busy_queue = pBusy;
677     }
678     else
679     {
680         struct busy_block *ptemp = busy_queue;
681         while(ptemp && ptemp->next)
682         {
683             ptemp = ptemp->next;
684         }
685         ptemp->next = pBusy;
686     }
687     ++nBusy;
688     printf("完成插入分配块——开始地址：%d，大小：%d
",pBusy->start, pBusy->size);
689 }
690 
691 void insert_free(struct free_block *pFree)
692 {
693     if(!free_queue)
694     {
695         free_queue = pFree;
696     }
697     else
698     {
699         struct free_block *ptemp = free_queue;
700         while(ptemp && ptemp->next)
701         {
702             ptemp = ptemp->next;
703         }
704         ptemp->next = pFree;
705     }
706     ++nFree;
707     printf("完成插入空闲——开始地址：%d，大小：%d
",pFree->start, pFree->size);
708 
709 }
710 void delete_free(struct free_block *pFree, struct free_block *pLeft)
711 {
712     struct free_block *ptemp = free_queue;
713     struct free_block *pre = NULL;
714     if(!ptemp)return;
715     while(ptemp)
716     {
717         if(ptemp == pFree)
718         {
719             break;
720         }
721         pre = ptemp;
722         ptemp = ptemp->next;
723     }
724     if(pre)
725     {
726         if(pLeft->size == 0)
727         {
728             pre->next = ptemp->next;
729             free(pLeft);
730         }
731         else
732         {
733             pre->next = pLeft;
734         }
735         free(ptemp);
736     }
737     else
738     {
739         if(pLeft->size == 0)
740         {
741             free_queue = ptemp->next;
742             free(pLeft);
743         }       
744         else
745             free_queue = pLeft;
746 
747             free(ptemp);
748     }
749     --nFree;
750 }
751 
752 void fifo_delete_busy()
753 {
754     if(busy_queue)
755     {
756         struct busy_block *ptemp = busy_queue;
757         busy_queue = busy_queue->next;
758         free(ptemp);
759     }
760     else
761     {
762         printf("busy空
");
763     }
764     --nBusy;
765 }
766 void lifo_delete_busy()
767 {
768     if(busy_queue)
769     {
770         struct busy_block *ptemp = busy_queue;
771         struct busy_block *pre = NULL;
772         while(ptemp && ptemp->next)
773         {
774             pre = ptemp;
775             ptemp = ptemp->next;
776         }
777         if(!pre)
778         {
779             busy_queue = NULL;
780         }
781         else
782         {
783             pre->next = NULL;
784         }
785         free(ptemp);
786         ptemp = NULL;
787     }
788     else
789     {
790         printf("busy空
");
791     }
792     --nBusy;
793 }
794 void show_free()
795 {
796     if(free_queue)
797     {
798         struct free_block *ptemp = free_queue;
799         printf("显示空闲块：
");
800         while(ptemp)
801         {
802             printf("————开始：%d，大小：%d
",ptemp->start, ptemp->size);
803             ptemp = ptemp->next;
804         }
805         printf("
");
806     }
807     else
808     {
809         printf("当前无空闲块
");
810     }
811 }
812 
813 void show_busy()
814 {
815     if(busy_queue)
816     {
817         struct busy_block *ptemp = busy_queue;
818         printf("显示已分配块：
");
819         while(ptemp)
820         {
821             printf("—————————序号:%d，开始：%d，大小：%d，数据：",ptemp->id, ptemp->start, ptemp->size);
822             for(int i=0; i<ptemp->size; ++i)
823             {
824                 printf("%c",ptemp->data[i]);
825             }
826             printf("
");
827             ptemp = ptemp->next;
828         }    
829         printf("
");
830     }
831     else
832     {
833         printf("当前无分配块
");
834     }
835 }
836 
837 void merge_in()
838 {
839     free_queue = merge_free(free_queue);
840     printf("紧缩完成
");
841 }
842 struct free_block * merge_free(struct free_block *f)
843 {
844     if(f && f->next)
845     {
846         f->next = merge_free(f->next);
847         if(f->next && (f->start + f->size == f->next->start))
848         {
849             struct free_block *p = f->next;
850             f->next = p->next;
851             f->size += p->size;
852             free(p);
853             p=NULL;
854         }
855     }
856     return f;
857 }
858 void fifo()
859 {
860     if(busy_queue)
861     {
862         printf("————————————————————————————————被调出的信息:序号：%d，开始地址：%d，大小：%d, 数据:", 
863                                     busy_queue->id, busy_queue->start, busy_queue->size);
864         for(int k=0; k<busy_queue->size; ++k)
865         {
866             printf("%c",busy_queue->data[k]);
867         }
868         printf("————————————————————————————————
");
869         printf("————————————————————————————————调度次数：%d————————————————————————————————
",++ScheduleCnt);
870         struct free_block *pFree = create_free(busy_queue->start, busy_queue->size, NULL);
871         insert_free(pFree);
872         fifo_delete_busy();
873     }
874     else
875     {
876         printf("无分配块，无法调出
");
877     }
878 }
879 void lifo()
880 {
881     if(busy_queue)
882     {
883         struct busy_block *pBusy = busy_queue;
884         while(pBusy && pBusy->next)
885         {
886             pBusy = pBusy->next;
887         }
888         printf("被调出的信息:开始地址：%d，大小：%d, 数据：", pBusy->start, pBusy->size);
889         for(int k=0; k<pBusy->size; ++k)
890         {
891             printf("%c",pBusy->data[k]);
892         }
893         printf("
");
894         struct free_block *pFree = create_free(pBusy->start, pBusy->size, NULL);
895         insert_free(pFree);
896         lifo_delete_busy();
897     }
898     else
899     {
900         printf("无分配块，无法调出
");
901     }
902 }

二版成品

  1 #include <stdio.h>
  2 #include <stdlib.h>
  3 #include <string.h>
  4 #include <semaphore.h>
  5 #include <unistd.h>
  6 #include <time.h>
  7 #include <sys/types.h>
  8 #include <pthread.h>
  9 #define bool int
 10 #define true 1
 11 #define false 0
 12 #define THREAD_MAXN 3//线程数
 13 #define RUNTIME_SUB 1//每次运行线程减去的运行时间
 14 #define RUN_TIME 20//线程运行时间
 15 #define INIT_FREE_BLOCK_NUM 8//内存块初始数量
 16 #define INIT_FREE_BLOCK_SIZE 10//内存块初始大小
 17 #define FREE_MAXN 100//最大空闲块数量
 18 #define STU_NUM 20//学生数量
 19 //-----结构体定义
 20 typedef struct TCB//存储线程信息
 21 {
 22     int thread_id;//线程编号
 23     int arriveTime;//线程到达时间
 24     int runTime;//持续时间
 25     int finishTime;//完成时间
 26     int wholeTime;//周转时间
 27     double weightWholeTime;//带权周转时间
 28     bool Finished;//线程是否完成
 29     struct TCB* next;//使用链式存储方式
 30 }TCB;
 31 struct tcb_queue//TCB队列定义
 32 {
 33     struct TCB* tcbQueue[THREAD_MAXN];//TCB指针数组
 34     int r,f;
 35 };
 36 struct thread_pool//线程池结构体
 37 {
 38     pthread_mutex_t tcb_lock;//互斥锁
 39     int fDestroyed;//线程池是否被销毁
 40     pthread_t *threadid;//存储线程标识符指针
 41     struct TCB *nowRunThread;//指向当前正在运行的线程     
 42     int nFinish;//完成线程数
 43     sem_t sem[THREAD_MAXN];//用于控制线程的信号量
 44     struct tcb_queue rrQueue;//轮转队列
 45     struct tcb_queue showQueue;//用于辅助打印的队列
 46     struct TCB *tcb;//存储TCB
 47 };
 48 struct free_block//空闲块结构体
 49 {
 50     int start;//起始位置
 51     int size;
 52     struct free_block *next;
 53 };
 54 struct busy_block//被分配的内存块
 55 {
 56     int id;//编号
 57     int start;
 58     int size;
 59     char *data;//根据需要动态分配
 60     struct busy_blocl *next;
 61 };
 62 struct student//储存学生信息
 63 {
 64     char number[9];
 65     char name[41];
 66     int name_size;
 67 };
 68 //-----全局变量定义
 69 static struct thread_pool *pool = NULL;//全局变量pool，指向线程池
 70 int nowTime;//当前已走过的时间
 71 int busy_cnt = -1;//分配块编号计数器
 72 int nFree = 0;//空闲块数量
 73 int nBusy = 0;//已分配块数量
 74 int nameCnt = 0;//名字存储计数器
 75 int numCnt = 0;//学号存储计数器
 76 int ScheduleCnt = 0;//调度次数
 77 struct free_block *free_queue = NULL;//储存空闲块的链表
 78 struct busy_block *busy_queue = NULL;//储存已分配块的链表
 79 struct student student_info[STU_NUM];
 80 //-----函数声明
 81 void TCB_bubble();//给TCB排序
 82 void show_rr();//打印轮转队列
 83 void show_tcb();//打印所有线程的信息
 84 void pool_init();//初始化线程池
 85 void *thread_run_func(void* param);//线程里运行的函数
 86 void round_robin();//时间片轮转算法的调度函数
 87 int pool_destroy();//销毁线程池
 88 void init_free();//初始化空闲块
 89 struct free_block* create_free(int start, int size, struct free_block *next);//创建一个空闲块
 90 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data);//创建一个已分配块
 91 struct free_block * merge_free(struct free_block *f);//合并所有能够合并的空闲内存块
 92 void init_student();//初始化学生的学号，姓名，采用随机生成的方法
 93 void insert_busy(struct busy_block *pBusy);//尾插法插入一个分配块到链表busy_queue中
 94 void insert_free(struct free_block *pFree);//尾插法插入一个空闲块到链表free_queue中
 95 void delete_free(struct free_block *pFree, int size);//删除一个空闲块中被占用的部分，保留剩余部分
 96 void fifo_delete_busy();//fifo算法中删除分配块
 97 void lifo_delete_busy();//lifo算法中删除分配块
 98 void show_free();//显示空闲块链表   
 99 void show_busy();//显示分配块链表
100 void FF_bubble();//按照start升序，对空闲块冒泡排序
101 void BF_bubble();//按照size升序，对空闲块冒泡排序
102 void WF_bubble();//按照size降序，对空闲块冒泡排序  
103 void merge_in();//合并空闲内存块函数的入口
104 void fifo();//fifo算法调出分配块
105 void lifo();//lifo算法调出分配块
106 //main
107 int main()
108 {  
109     init_student();
110     init_free();
111     pool_init();
112     TCB_bubble();
113     show_tcb();
114     round_robin();
115     sleep(5);//等待所有线程完成
116     pool_destroy();
117     return 0;
118 }
119 //函数定义
120 void TCB_bubble()//给TCB排序,按arriveTime升序排列
121 {
122     TCB* ptemp = NULL;
123     for(int i=0; i<THREAD_MAXN; ++i)
124     {
125         ptemp = pool->tcb;
126         while(ptemp && ptemp->next)
127         {
128             if(ptemp->arriveTime > ptemp->next->arriveTime)
129             {//交换两个节点
130                 TCB *p_next = ptemp->next->next;
131                 TCB *p_pre = ptemp;//后面ptemp = ptemp->next，当前ptemp相当于pre
132                 TCB *p_pre_pre = pool->tcb;//pre的pre
133                 if(p_pre_pre == p_pre)//说明ptemp是头结点
134                 {
135                     p_pre_pre = NULL;
136                 }
137                 else//否则找到pre_pre所在位置
138                 {
139                     while(p_pre_pre && p_pre_pre->next != p_pre)
140                     {
141                         p_pre_pre = p_pre_pre->next;
142                     }
143                 }
144                 //交换结点
145                 ptemp = ptemp->next;
146                 ptemp->next = p_pre;
147                 p_pre->next = p_next;
148                 if(p_pre_pre)
149                 {
150                     p_pre_pre->next = ptemp;
151                 }
152                 else
153                 {
154                     pool->tcb = ptemp;
155                 } 
156             }
157             ptemp = ptemp->next;
158         }    
159     }
160 }
161 void show_rr()//打印轮转队列
162 {
163     printf("当前时间为：%d
",nowTime);
164     if(pool->rrQueue.f == pool->rrQueue.r)
165     {
166         printf("目前还没有线程到达
");
167     }
168     else
169     {
170         printf("目前轮转队列为：
");
171     }
172     while(pool->rrQueue.f != pool->rrQueue.r)
173     {
174         pool->showQueue.f = (pool->showQueue.f + 1) % THREAD_MAXN;
175         pool->rrQueue.f = (pool->rrQueue.f + 1) % THREAD_MAXN;
176         pool->showQueue.tcbQueue[pool->showQueue.f] = pool->rrQueue.tcbQueue[pool->rrQueue.f];
177         printf("%d ",pool->rrQueue.tcbQueue[pool->rrQueue.f]->thread_id);
178     }
179     while(pool->showQueue.r != pool->showQueue.f)//将队列放回
180     {
181         pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
182         pool->showQueue.r = (pool->showQueue.r + 1) % THREAD_MAXN;
183         pool->rrQueue.tcbQueue[pool->rrQueue.r] = pool->showQueue.tcbQueue[pool->showQueue.r];
184     }
185     printf("

");
186 }
187 void show_tcb()//打印所有线程的信息
188 {
189 TCB *ptemp = pool->tcb;
190 printf("打印所有线程的信息：
");
191 while(ptemp)
192 {
193     printf("线程%d：到达时间：%d，剩余时间：%d
", ptemp->thread_id, ptemp->arriveTime, ptemp->runTime);
194     ptemp = ptemp->next;
195 }
196 printf("
");
197 }
198 void pool_init()//初始化线程池
199 {
200     pool = (struct thread_pool*)malloc(sizeof(struct thread_pool));
201     pthread_mutex_init(&(pool->tcb_lock), NULL);//初始为未锁住状态
202     pool->fDestroyed = 0;//线程池是否被销毁
203     pool->nFinish = 0;
204     pool->nowRunThread = NULL;//指向当前正在运行的线程 
205     pool->rrQueue.f = pool->rrQueue.r = 0;//轮转队列
206     pool->showQueue.r = pool->showQueue.r = 0;//用于辅助打印的队列
207     pool->tcb = NULL;
208     //创建并初始化TCB
209     TCB* ptemp = pool->tcb;
210     srand(time(0));
211     for(int i=0; i<THREAD_MAXN-1; ++i)
212     {
213         TCB* s = (TCB*)malloc(sizeof(TCB));
214     // s->arriveTime = rand()%9;
215         s->arriveTime = 0;
216         s->runTime = RUN_TIME;
217         s->thread_id = i;//编号令为0
218         s->Finished = false;
219         s->next = NULL;
220         //尾插入
221         if(!pool->tcb)//第一个节点
222         {
223             pool->tcb = s;
224         }
225         else
226         {
227             ptemp = pool->tcb;
228             while(ptemp && ptemp->next)
229             {
230                 ptemp = ptemp->next;
231             }
232             ptemp->next = s;
233         }
234     }
235     //初始化信号量
236     ptemp = pool->tcb;
237     int i=0;
238     while(ptemp)
239     {
240         int i = ptemp->thread_id;
241         sem_init(&(pool->sem[i]), 0, 0);
242         ptemp = ptemp->next;
243     }
244     //创建线程
245     ptemp = pool->tcb;
246     pool->threadid = (pthread_t*)malloc(sizeof(pthread_t) * THREAD_MAXN);
247     while(ptemp)
248     {
249         //把ptemp作为参数传入thread_run_func()
250         int t;
251         t = pthread_create(&(pool->threadid[ptemp->thread_id]), 
252                                 NULL, thread_run_func, ptemp);
253         if(!t)//线程创建成功
254         {
255             printf("线程%d创建成功!
", ptemp->thread_id);
256         }
257         else
258         {
259             printf("线程创建失败!
");
260         }
261         ptemp = ptemp->next;
262     }
263     printf("线程池pool初始化完成！
");
264 }
265 void *thread_run_func(void *param)//线程里运行的函数
266 {
267     TCB *ptemp = (TCB*)param;
268     while(ptemp->runTime > 0)
269     {
270         //printf("线程%d正在等待……
", ptemp->thread_id);
271         sleep(1);
272         sem_wait(&(pool->sem[ptemp->thread_id]));//唤醒
273         //printf("线程%d已被唤醒！
",ptemp->thread_id);
274         pthread_mutex_lock(&(pool->tcb_lock));//上互斥锁
275         ptemp->runTime -= RUNTIME_SUB;
276         //线程操作
277         int i = numCnt;
278         int j = nameCnt;
279         struct free_block *pFree = NULL;
280         struct busy_block *pBusy = NULL;
281         if(ptemp->thread_id == 0)//store number
282         {  
283             printf("将要放入内存的信息：");
284             for(int c=0; c<8; ++c)
285             {
286                 printf("%c",student_info[i].number[c]);
287             }   
288             printf("，大小：8
");
289             printf("将所有空闲内存块紧缩
");
290             //紧缩
291             FF_bubble();
292             merge_in();
293             BF_bubble();
294             //WF_bubble();   
295 
296             show_free();
297             pFree = free_queue;
298             pBusy = busy_queue;
299             int fEnough = 0;//内存大小是否足够
300             while(!fEnough)
301             {
302                 if(pFree && pFree->size >= 8 )
303                 {
304                     fEnough = 1; 
305                     ++numCnt;
306                     pBusy = create_busy(pFree->start, 8, NULL, student_info[i].number);
307                     printf("正在存储的信息：开始地址:%d, 大小:8
",pFree->start);
308                     delete_free(pFree, 8);
309                     insert_busy(pBusy);
310                     show_busy();
311                     break;
312                 }
313                 else
314                 {
315                     if(pFree)
316                     {
317                         printf("当前指向空闲内存大小不够，跳到下一块空闲内存
");
318                         pFree = pFree->next;
319                         sleep(1);
320                     }
321                     else
322                     {
323                         printf("没有足够大小的空闲内存可用，开始调度：
");
324                         fifo(ptemp->thread_id);
325                         //lifo(ptemp->thread_id);
326                         printf("将所有空闲内存块紧缩
");
327                         FF_bubble();
328                         merge_in();//紧缩
329                         BF_bubble();
330                         //WF_bubble();   
331                         show_free();
332                         pFree = free_queue;
333                     }
334                 }
335             }  
336         }
337         else//store name
338         {  
339         printf("将要放入内存的信息：");
340         for(int c=0; c<student_info[j].name_size; ++c)
341         {
342             printf("%c",student_info[j].name[c]);
343         }
344         printf("，大小：%d
",student_info[j].name_size);
345         printf("将所有空闲内存块紧缩
");
346 
347         FF_bubble();
348         merge_in();//紧缩
349         BF_bubble();
350         //WF_bubble();   
351         show_free();
352         pFree = free_queue;
353         pBusy = busy_queue;
354         int fEnough = 0;
355         while(!fEnough)
356         {
357             if(pFree && pFree->size >= student_info[j].name_size )
358             {   
359                 fEnough = 1;
360                 ++nameCnt;
361                 pBusy = create_busy(pFree->start, student_info[j].name_size, NULL, student_info[j].name);
362                 printf("正在存储的信息：开始地址:%d, 大小:%d
", pFree->start, student_info[j].name_size);
363                 delete_free(pFree, student_info[j].name_size);
364                 insert_busy(pBusy);
365                 show_busy();
366                 break;
367             }
368             else
369             {
370                 if(pFree)
371                 {
372                     printf("当前指向空闲内存大小不够，跳到下一块空闲内存
");
373                     pFree = pFree->next;
374                     sleep(1);
375                 }
376                 else//FIFO
377                 {
378                     printf("没有足够大小的空闲内存可用，开始调度：
");
379                     fifo(ptemp->thread_id);
380                     //lifo(ptemp->thread_id);
381                     printf("将所有空闲内存块紧缩
");
382                     FF_bubble();
383                     merge_in();//紧缩
384                     BF_bubble();
385                     //WF_bubble();   
386                     show_free();
387                     pFree = free_queue;
388                 }
389             }
390         }  
391     }  
392     //线程操作  
393     //printf("当前时间为：%d，轮转的线程为线程%d，该线程剩余时间：%d->%d
",
394             nowTime, ptemp->thread_id, ptemp->runTime+RUNTIME_SUB, ptemp->runTime<0?0:ptemp->runTime);
395     //sleep(1);
396     if(ptemp->runTime <= 0)//线程已经完成
397     {
398         ++pool->nFinish;
399         ptemp->Finished = true;
400         //出队
401         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
402     }
403     else
404     {//还未完成
405         //出队
406         pool->rrQueue.f = (pool->rrQueue.f+1)%THREAD_MAXN;
407         //入队
408         pool->rrQueue.r = (pool->rrQueue.r + 1) % THREAD_MAXN;
409         pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
410     }
411     pthread_mutex_unlock(&(pool->tcb_lock));
412     sleep(1);
413 }
414     pthread_exit(NULL);
415 }
416 void round_robin()//时间片轮转算法的调度函数
417 {
418     TCB *ptemp = pool->tcb;
419     while(1)
420     {
421         sleep(1);
422         pthread_mutex_lock(&(pool->tcb_lock));
423         if(pool->nFinish == THREAD_MAXN-1)//所有线程完成
424             break;
425         while(ptemp && ptemp->arriveTime == nowTime)
426         {
427             //printf("当前时间为：%d，线程%d进入轮转队列，运行时间：%d
", 
428             nowTime, ptemp->thread_id, ptemp->runTime);
429             pool->rrQueue.r = (pool->rrQueue.r+1)%THREAD_MAXN;
430             pool->rrQueue.tcbQueue[pool->rrQueue.r] = ptemp;
431             ptemp = ptemp->next;
432         }
433         if(pool->rrQueue.f != pool->rrQueue.r)
434         {
435             pool->nowRunThread = pool->rrQueue.tcbQueue[(pool->rrQueue.f+1)%THREAD_MAXN];
436             //printf("准备唤醒线程%d
",pool->nowRunThread->thread_id);
437             sleep(1);
438             sem_post(&(pool->sem[pool->nowRunThread->thread_id]));
439         }
440         //show_rr();
441         ++nowTime;
442         pthread_mutex_unlock(&(pool->tcb_lock));
443         sleep(1);
444     }
445 }
446 int pool_destroy()//销毁线程池
447 {
448     if(pool->fDestroyed)//防止重复销毁
449         return -1;
450     pool->fDestroyed = 1;
451     TCB* ptemp = pool->tcb;
452     while(ptemp)
453     {
454         pthread_join(pool->threadid[ptemp->thread_id], NULL);
455         printf("线程%d已结束
",ptemp->thread_id);
456         ptemp = ptemp->next;
457     }
458     free(ptemp);
459     free(pool->threadid);
460     pthread_mutex_destroy(&(pool->tcb_lock));
461     free(pool);
462     pool = NULL;
463     printf("线程池pool已被销毁！
");
464 }
465 
466 //----------------------------------------------------------------------------------
467 
468 void init_free()
469 {
470     int start_address = 0;
471     struct free_block *ptemp = NULL;
472     for(int i=0; i<INIT_FREE_BLOCK_NUM; ++i)
473     {
474         struct free_block* s = create_free(start_address, INIT_FREE_BLOCK_SIZE, NULL);
475         printf("已创建起始地址为%d，大小为%d的空闲块！
", s->start, s->size);
476         ++nFree;
477         if(!free_queue)
478         {
479             free_queue = s;
480         }
481         else
482         {
483             ptemp = free_queue;
484             while(ptemp && ptemp->next)
485             {
486                 ptemp = ptemp->next;
487             }
488             ptemp->next = s;
489         }
490         start_address += INIT_FREE_BLOCK_SIZE;
491     }
492     printf("空闲内存块初始化完成！
");
493     show_free();
494 }
495 struct free_block* create_free(int start, int size, struct free_block *next)
496 {
497     struct free_block *s = (struct free_block*)malloc(sizeof(struct free_block));
498     s->start = start;
499     s->size = size;
500     s->next = next;
501     return s;
502 }
503 struct busy_block* create_busy(int start, int size, struct busy_block *next, char *data)
504 {
505     struct busy_block *s = (struct busy_block*)malloc(sizeof(struct busy_block));
506     s->start = start;
507     s->id = ++busy_cnt;
508     s->next = NULL;
509     s->size = size;
510     s->data = (char*)malloc(sizeof(char) * size);
511     for(int i=0; i<size; ++i)
512     {
513         s->data[i] = data[i];
514     }   
515     return s;
516 }
517 void init_student()
518 {
519     srand(time(0));
520     for(int i=0; i<STU_NUM; ++i)
521     {
522         strcpy(student_info[i].number, "201820");
523         if(i < 10)
524         {
525             student_info[i].number[6] = '0';
526             student_info[i].number[7] = '0' + i;
527         }
528         else
529         {
530             student_info[i].number[6] = '0' + i/10;
531             student_info[i].number[7] = '0' + i%10;
532         }
533         student_info[i].number[8] = '';
534            int ran = rand()%37;
535         student_info[i].name_size = 4+ran;//拼音长度：4~40
536         for(int j=0; j<student_info[i].name_size; ++j)
537         {
538             if(i < 26)
539             {
540                 student_info[i].name[j] = (char)('a' + i);
541             }
542             else
543             {
544                 student_info[i].name[j] = (char)('A' + i - 26);
545             }
546         }
547         student_info[i].name[4+ran] = '';
548         printf("编号：%d，姓名：%s，姓名大小：%d，学号：%s
", i, student_info[i].name, student_info[i].name_size, student_info[i].number);
549     }
550     printf("学生信息初始化完成！
");
551 }
552 void FF_bubble()
553 {
554     struct free_block* ptemp = NULL;
555     if(free_queue)
556     for(int i=0; i<FREE_MAXN; ++i)
557     {
558         ptemp = free_queue; 
559         while(ptemp && ptemp->next)
560         {
561             if(ptemp->start > ptemp->next->start )
562             {//交换两个节点
563                 struct free_block *p_next = ptemp->next->next;
564                 struct free_block *p_pre = ptemp;
565                 struct free_block *p_pre_pre = free_queue;
566                 if(p_pre_pre == p_pre)
567                 {
568                     p_pre_pre = NULL;
569                 }
570                 else
571                 {
572                     while(p_pre_pre && p_pre_pre->next != p_pre)
573                     {
574                         p_pre_pre = p_pre_pre->next;
575                     }
576                 }
577                 ptemp = ptemp->next;
578                 ptemp->next = p_pre;
579                 p_pre->next = p_next;
580                 if(p_pre_pre)
581                 {
582                     p_pre_pre->next = ptemp;
583                 }
584                 else
585                 {
586                     free_queue = ptemp;
587                 } 
588             }
589             ptemp = ptemp->next;
590         }    
591     }
592 }
593 void BF_bubble()
594 {
595     struct free_block* ptemp = NULL;
596     if(free_queue)
597     for(int i=0; i<FREE_MAXN; ++i)
598     {
599         ptemp = free_queue; 
600         while(ptemp && ptemp->next)
601         {
602             if(ptemp->size > ptemp->next->size )
603             {//交换两个节点
604                 struct free_block *p_next = ptemp->next->next;
605                 struct free_block *p_pre = ptemp;
606                 struct free_block *p_pre_pre = free_queue;
607                 if(p_pre_pre == p_pre)
608                 {
609                     p_pre_pre = NULL;
610                 }
611                 else
612                 {
613                     while(p_pre_pre && p_pre_pre->next != p_pre)
614                     {
615                         p_pre_pre = p_pre_pre->next;
616                     }
617                 }
618                 ptemp = ptemp->next;
619                 ptemp->next = p_pre;
620                 p_pre->next = p_next;
621                 if(p_pre_pre)
622                 {
623                     p_pre_pre->next = ptemp;
624                 }
625                 else
626                 {
627                     free_queue = ptemp;
628                 } 
629             }
630             ptemp = ptemp->next;
631         }    
632     }
633 }
634 void WF_bubble()
635 {
636     struct free_block* ptemp = NULL;
637     if(free_queue!=NULL)
638     for(int i=0; i<FREE_MAXN; ++i)
639     {
640         ptemp = free_queue; 
641         while(ptemp && ptemp->next)
642         {
643             if(ptemp->size < ptemp->next->size )
644             {//交换两个节点
645                 struct free_block *p_next = ptemp->next->next;
646                 struct free_block *p_pre = ptemp;
647                 struct free_block *p_pre_pre = free_queue;
648                 if(p_pre_pre == p_pre)
649                 {
650                     p_pre_pre = NULL;
651                 }
652                 else
653                 {
654                     while(p_pre_pre && p_pre_pre->next != p_pre)
655                     {
656                         p_pre_pre = p_pre_pre->next;
657                     }
658                 }
659                 ptemp = ptemp->next;
660                 ptemp->next = p_pre;
661                 p_pre->next = p_next;
662                 if(p_pre_pre)
663                 {
664                     p_pre_pre->next = ptemp;
665                 }
666                 else
667                 {
668                     free_queue = ptemp;
669                 } 
670             }
671             ptemp = ptemp->next;
672         }    
673     }
674 }
675 
676 void insert_busy(struct busy_block *pBusy)
677 {
678     if(!busy_queue) 
679     {
680         busy_queue = pBusy;
681     }
682     else
683     {
684         struct busy_block *ptemp = busy_queue;
685         while(ptemp && ptemp->next)
686         {
687             ptemp = ptemp->next;
688         }
689         ptemp->next = pBusy;
690     }
691     ++nBusy;
692     printf("完成插入分配块——开始地址：%d，大小：%d
",pBusy->start, pBusy->size);
693     return;
694 }
695 
696 void insert_free(struct free_block *pFree)
697 {
698     if(!free_queue)
699     {
700         free_queue = pFree;
701     }
702     else
703     {
704         struct free_block *ptemp = free_queue;
705         while(ptemp && ptemp->next)
706         {
707             ptemp = ptemp->next;
708         }
709         ptemp->next = pFree;
710     }
711     ++nFree;
712     printf("完成插入空闲块——开始地址：%d，大小：%d
",pFree->start, pFree->size);
713     return;
714 }
715 void delete_free(struct free_block *pFree, int size)
716 {
717     if(!free_queue)return;
718     struct free_block *ptemp = free_queue;
719     struct free_block *pre = NULL;
720     while(ptemp)
721     {
722         if(ptemp == pFree)
723         {
724             if(pre)
725             {
726                 if(pFree->size == size)//无剩余
727                 {
728                     --nFree;
729                     pre->next = ptemp->next;
730                 }
731                 else
732                 {
733                     pre->next = create_free(pFree->start+size, pFree->size-size, ptemp->next);
734                 }
735             }
736             else
737             {
738                 if(pFree->size == size)
739                 {
740                     free_queue = ptemp->next;
741                 }       
742                 else
743                 {
744                     free_queue = create_free(pFree->start+size, pFree->size-size, ptemp->next);
745                 }  
746             }
747             free(ptemp);
748             ptemp=NULL;
749             break;
750         }
751         pre = ptemp;
752         ptemp = ptemp->next;
753     }
754     return;
755 }
756 void fifo_delete_busy()
757 {
758     if(busy_queue)
759     {
760         struct busy_block *ptemp = busy_queue;
761         busy_queue = busy_queue->next;
762         free(ptemp);    
763         ptemp=NULL;
764         --nBusy;
765     }
766     else
767     {
768         printf("无分配块
");
769     }
770 }
771 void lifo_delete_busy()
772 {
773     if(busy_queue)
774     {
775         struct busy_block *ptemp = busy_queue;
776         struct busy_block *pre = NULL;
777         while(ptemp && ptemp->next)
778         {
779             pre = ptemp;
780             ptemp = ptemp->next;
781         }
782         if(!pre)
783         {
784             busy_queue = NULL;
785         }
786         else
787         {
788             pre->next = NULL;
789         }
790         free(ptemp);
791         ptemp = NULL;   
792         --nBusy;
793     }
794     else
795     {
796         printf("无分配块
");
797     }
798     return;
799 }
800 void show_free()
801 {
802     if(free_queue)
803     {
804         struct free_block *ptemp = free_queue;
805         printf("显示空闲块：
");
806         while(ptemp)
807         {
808             printf("————开始：%d，大小：%d
",ptemp->start, ptemp->size);
809             ptemp = ptemp->next;
810         }
811         printf("
");
812     }
813     else
814     {
815         printf("当前无空闲块
");
816     }
817     return;
818 }
819 void show_busy()
820 {
821     if(busy_queue)
822     {
823         struct busy_block *ptemp = busy_queue;
824         printf("显示已分配块：
");
825         while(ptemp)
826         {
827             printf("—————————序号:%d，开始：%d，大小：%d，数据：",ptemp->id, ptemp->start, ptemp->size);
828             for(int i=0; i<ptemp->size; ++i)
829             {
830                 printf("%c",ptemp->data[i]);
831             }
832             printf("
");
833             ptemp = ptemp->next;
834         }    
835         printf("
");
836     }
837     else
838     {
839         printf("当前无分配块
");
840     }
841     return;
842 }
843 void merge_in()
844 {
845     free_queue = merge_free(free_queue);
846     printf("紧缩完成
");
847     return;
848 }
849 struct free_block * merge_free(struct free_block *f)
850 {
851     if(f && f->next)
852     {
853         f->next = merge_free(f->next);
854         if(f->next && (f->start + f->size == f->next->start))
855         {
856             struct free_block *p = f->next;
857             f->next = p->next;
858             f->size += p->size;
859             free(p);
860             p=NULL;
861         }
862     }
863     return f;
864 }
865 void fifo(int thread_id)
866 {
867     if(busy_queue)
868     {
869         printf("————————————————————————————————被调出的信息:序号：%d，开始地址：%d，大小：%d, 数据:", 
870                                     busy_queue->id, busy_queue->start, busy_queue->size);
871         for(int k=0; k<busy_queue->size; ++k)
872         {
873             printf("%c",busy_queue->data[k]);
874         }
875         printf("————————————————————————————————
");
876         printf("————————————————————————————————调度次数：%d，当前线程号：%d————————————————————————————————
",++ScheduleCnt,thread_id);
877         struct free_block *pFree = create_free(busy_queue->start, busy_queue->size, NULL);
878         insert_free(pFree);
879         fifo_delete_busy();
880     }
881     else
882     {
883         printf("无分配块，无法调出
");
884     }
885     return;
886 }
887 void lifo(int thread_id)
888 {
889     if(busy_queue)
890     {
891         struct busy_block *ptemp = busy_queue;
892         while(ptemp && ptemp->next)
893         {
894             ptemp = ptemp->next;
895         }
896         printf("————————————————————————————————被调出的信息:序号：%d，开始地址：%d，大小：%d, 数据:", 
897                                     ptemp->id, ptemp->start, ptemp->size);
898         for(int k=0; k<ptemp->size; ++k)
899         {
900             printf("%c", ptemp->data[k]);
901         }
902         printf("————————————————————————————————
");
903         printf("————————————————————————————————调度次数：%d，当前线程号：%d————————————————————————————————
",++ScheduleCnt,thread_id);
904         struct free_block *pFree = create_free(ptemp->start, ptemp->size, NULL);
905         insert_free(pFree);
906         lifo_delete_busy();
907     }
908     else
909     {
910         printf("无分配块，无法调出
");
911     }
912     return;
913 }

船新版本

查看全文

相关阅读:
Nginx 本地建立负载均衡（Windows环境）
Nginx 代理本地文件夹（Windows环境）
PostGIS 使用Mysql_fdw同步ArcGIS填坑记录
 PostGIS mysql_fdw操作日志（留观）
PostGIS mysql_fdw使用（Linux）
PostGIS mysql_fdw安装（Linux）
PostGIS 安装教程（Linux）（二）
PostGIS 安装教程（Linux）（一）
Linux 命令记录
 PostGIS 查看表属性（字段、类型、是否为空）

原文地址：https://www.cnblogs.com/2020R/p/13278882.html