int main() { pthread_t readers[MAX_READERS]; pthread_t writers[MAX_WRITERS]; // 初始化互斥锁 if (pthread_mutex_init(&mutex, NULL) != 0) { fprintf(stderr, "被初始化为互斥。\n"); return EXIT_FAILURE; } // 创建读者线程 for (int i = 0; i < MAX_READERS; i++) { int *id = (int *) malloc(sizeof(int)); *id = i + 1; if (pthread_create(&readers[i], NULL, reader, id) != 0) { fprintf(stderr, "未能创建读取器线程%d。\n", i + 1); return EXIT_FAILURE; } } // 创建写者线程 for (int i = 0; i < MAX_WRITERS; i++) { int *id = (int *) malloc(sizeof(int)); *id = i + 1; if (pthread_create(&writers[i], NULL, writer, id) != 0) { fprintf(stderr, "创建写入线程%d的失败。\n", i + 1); return EXIT_FAILURE; } } // 等待所有线程结束 for (int i = 0; i < MAX_READERS; i++) { pthread_join(readers[i], NULL); } for (int i = 0; i < MAX_WRITERS; i++) { pthread_join(writers[i], NULL); } // 销毁互斥锁 pthread_mutex_destroy(&mutex); return EXIT_SUCCESS; }

这段代码实现了主函数，其中包含了创建并启动读者线程和写者线程的过程。具体来说，该函数的执行流程如下：

1. 创建互斥锁：首先，该函数会调用 pthread_mutex_init 函数来创建一个互斥锁 mutex，用于保护共享资源的访问。

2. 创建读者线程：接着，该函数会使用一个 for 循环创建 MAX_READERS 个读者线程。对于每个读者线程，它都会先分配一个整型变量 id，并将其赋值为该线程的编号。然后，该函数会使用 pthread_create 函数创建一个读者线程，并将 id 作为参数传递给该线程。

3. 创建写者线程：类似地，该函数会使用一个 for 循环创建 MAX_WRITERS 个写者线程。对于每个写者线程，它都会先分配一个整型变量 id，并将其赋值为该线程的编号。然后，该函数会使用 pthread_create 函数创建一个写者线程，并将 id 作为参数传递给该线程。

4. 等待所有线程结束：创建完所有的读者线程和写者线程之后，该函数会使用两个 for 循环分别调用 pthread_join 函数等待所有的读者线程和写者线程结束。

5. 销毁互斥锁：最后，该函数会调用 pthread_mutex_destroy 函数销毁互斥锁 mutex，释放相关的资源。

需要注意的是，该函数中用到了两个常量 MAX_READERS 和 MAX_WRITERS，它们分别表示最大的读者线程数和写者线程数。同时，该函数还使用了两个全局变量 readers 和 writers，它们分别表示所有的读者线程和写者线程的线程标识符。