26 | 使用阻塞I/O和线程模型：换一种轻量的方式

第二题：可能会得到比正确的值小的值 i++大致分为三个步骤： 1、从内存读出i的值到寄存器 2、操作寄存器加1 3、将寄存器值写到i内存 多个线程去操作同一个全局变量的时候，可能某个线程在第二步的时候切换到另一个线程，这样就导致少加了。比如线程A 在i=1 的时候在第二步，这个时候寄存器加1值为2，在这个时候切换到线程B ，由于线程A还没有把2写到i里面，使用B读出来还是1，自增写到i里面，i为2，在切换到线程A，线程A将寄存器里面的2写到i，这样就少加了一次。

第一道，其实这里使用的生产者-消费者模型，可以使用扩容策略解决fd存放的问题。 第二题，在并发场景下很容易造成计算结果的不准确。因为这里面是两个线程各执行1000次。实际上很大结果是少于2000的结果。解决方法可以加上锁或volitate关键字（解决可见行问题）。

关于队列满的情况，额外加一个cond，表示队列未满条件就可以了。 typedef struct { int number; int *fd; int front; int rear; // 队列中当前元素数目 int count; pthread_mutex_t mutex; pthread_cond_t not_empty; // 队列未满条件 pthread_cond_t not_full; } block_queue; void block_queue_init(block_queue *blockQueue, int number) { blockQueue->number = number; blockQueue->fd = calloc(number, sizeof(int)); blockQueue->count = blockQueue->front = blockQueue->rear = 0; pthread_mutex_init(&blockQueue->mutex, NULL); pthread_cond_init(&blockQueue->not_empty, NULL); pthread_cond_init(&blockQueue->not_full, NULL); } void block_queue_push(block_queue *blockQueue, int fd) { pthread_mutex_lock(&blockQueue->mutex); while (blockQueue->count == blockQueue->number){ //队列满 pthread_cond_wait(&blockQueue->not_full, &blockQueue->mutex); } blockQueue->fd[blockQueue->rear] = fd; if (++blockQueue->rear == blockQueue->number) { blockQueue->rear = 0; } blockQueue->count++; printf("push fd %d", fd); pthread_cond_signal(&blockQueue->not_empty); pthread_mutex_unlock(&blockQueue->mutex); } int block_queue_pop(block_queue *blockQueue) { pthread_mutex_lock(&blockQueue->mutex); while (blockQueue->front == blockQueue->rear) // 空队列 pthread_cond_wait(&blockQueue->not_empty, &blockQueue->mutex); int fd = blockQueue->fd[blockQueue->front]; if (++blockQueue->front == blockQueue->number) { blockQueue->front = 0; } blockQueue->count--; printf("pop fd %d", fd); pthread_cond_signal(&blockQueue->not_full); // 解锁 pthread_mutex_unlock(&blockQueue->mutex); return fd; }

请问block_queue_pop的pthread_cond_wait为什么要放在while而不是if中

block_queue_push未考虑队列满的情况，可以在本函数里先判断是否队列满了，如果满就按某个策略扩容，例如扩大1.5或2倍。扩容失败或者容量超过最大值，就返回失败。

老师，请问一下，我跑了thread02这个程序。在没有客户端连上来的情况下，我发现四个子线程都执行到了block_queqe_pop函数里面，并都成功执行完pthread_mutex_lock，阻塞在后面的while循环里面。这里我想问的是四个子线程，不是最多只应该有一个能拿到互斥量，其他三个都应该阻塞在pthread_mutex_lock函数中么？

这个线程函数里面，没有调用close关闭connfd，导致，很多很多socket状态不对，没有正常进入time_wait状态 tcp4 0 0 127.0.0.1.43211 127.0.0.1.53703 CLOSE_WAIT tcp4 0 0 127.0.0.1.53703 127.0.0.1.43211 FIN_WAIT_2 tcp4 0 0 127.0.0.1.43211 127.0.0.1.53695 CLOSE_WAIT tcp4 0 0 127.0.0.1.53695 127.0.0.1.43211 FIN_WAIT_2

有个地方不太理解，一开始初始状态下，线程pop加锁了，为什么，有accept时候，执行push的时候获取锁怎么能成功呢，不是锁已经被pop用了，还没释放呢

老师我想问一下，线程的创建销毁和进程的创建销毁哪个开销比较大？

我自定义阻塞队列(多了个cnt计数元素个数，和条件变量分开来，实现起来清晰明了简单多了) typedef struct { int size; //队列容量 int *pFd; //存储队列元素，动态分配 int cnt; //队列当前元素个数 int pushIdx; //入队元素索引 int popIdx; //出对元素索引 pthread_mutex_t mutex; //锁 pthread_cond_t noFull; //非满，即队列元素个数cnt从size值，变成size - 1时的触发条件 pthread_cond_t noEmpty;//非空，即队列元素个数cnt从0值，变成1时的触发条件 }BlockQueue;