我在Linux上使用的是librdkafka-0.11.5 for C。我的C/C++应用程序只是将Kafka数据发送到web服务器,该服务器使用ElasticSearch驱动Kafka消费者。看起来在生产者端,Kafka为每个Unix进程增加了8(8)个内部线程。这给我们带来了一个问题,因为我们对每个Linux机器的线程数量有一个硬性限制。
有没有人知道为什么增加了8个线程?会不会是因为我的Linux机器有4个CPU,并且
我用c++编写了一个带有10个线程的项目。一个线程将数据加载到内存中(写缓冲区),另外9个线程同时读取缓冲区并将数据存储在SQLite数据库中,所有线程都使用互斥体进行处理以避免冲突。现在我需要评估这个项目的性能,比如每个线程的成功时间、内存使用情况等等。在c++环境下如何进行呢?我用Valgrind来检查这些。但我觉得不管用。/monerosci ==24262== C