最近碰到一个问题，生产者产生的内容需要尽快被消耗掉（发送出去），简单说就是处理的延迟要尽量小。
一开始，生产者是多个thrift server启动的worker thread，比如生产者的线程数是10，而消费者线程是1，这样导致消费者每次按照最大能力取也总取不尽。
后调整为一个生产者一个消费者，已敷使用。
这里还有个思路就是提高消费者线程的优先级(pthread_setschedparam， SCHED_FIFO)。这个还没尝试。
2023-11-10 19:40:40
最近碰到一个问题，生产者产生的内容需要尽快被消耗掉（发送出去），简单说就是处理的延迟要尽量小。
一开始，生产者是多个thrift server启动的worker thread，比如生产者的线程数是10，而消费者线程是1，这样导致消费者每次按照最大能力取也总取不尽。
后调整为一个生产者一个消费者，已敷使用。
这里还有个思路就是提高消费者线程的优先级(pthread_setschedparam， SCHED_FIFO)。这个还没尝试。