当前位置：首页 > news >正文

线程同步之双摄

news 2025/8/24 1:20:46

如何实现两个摄像头进行同步，并利用同步的信号做一些事情，比如stereo camera 做深度，如果是自己整的两个camera，同步就需要自己做，那么这时候可以利用线程同步手写一个，下面给一个示例代码：

multi_producer_one_consumer

这段代码展示了如何通过生产者-消费者模型实现两个相机的数据同步，基于时间戳来判断相机数据是否同步。代码使用了信号量（semaphores）、**条件变量（condition variables）以及互斥锁（mutexes）**来保证线程安全和数据同步。

信号量初始化：
- 简单理解信号量就是当前的缓存剩余个数，有了这个，你就不用定义数组的大小，它会帮你控制
- sem_init(&sem1, 0, MAX_ITEMS) 和 sem_init(&sem2, 0, MAX_ITEMS) 分别初始化了相机1和相机2的信号量，初始值为 MAX_ITEMS（假设为 10）。
- 初始值 10 表示队列中有 10 个可用的资源（例如 10 个空闲缓冲区空间）。
信号量操作：
- sem_wait(&sem1) 和 sem_wait(&sem2)：当信号量大于 0 时，信号量减 1，并允许线程继续执行；如果信号量等于 0，线程会阻塞，直到有可用的资源。
- 在使用sem_wait之后，如果线程没有被阻塞，也就是还有信号余量，那么就开始生产，这个时候，就需要上一个锁，保护内存。
- sem_post(&sem1) 和 sem_post(&sem2)：在数据处理完毕后，信号量加 1，表示释放了一个资源（例如，释放了队列中的一个空位）。
信号量的作用：确保每个相机生产者线程在队列未满时才能继续生产新数据，并在队列满时阻塞，直到有空余空间为止。信号量用来控制队列的可用资源。

条件变量的等待：
- 在使用条件变量的wait前一定要上一个锁，这个和sem.wait区别一下，这个锁上完之后，如果条件变量没有被满足，它会自动解锁。
- cond.wait(lock, [&] { return !cameraDataQueue1.empty() && !cameraDataQueue2.empty(); });
  - 消费者线程会等待条件变量，只有在两个相机的队列都有数据时才会唤醒并进行数据处理。
  - 该条件确保在比较时间戳时，相机1和相机2的数据都已准备好。
条件变量的通知：
- cond.notify_one();：生产者线程在生产完数据后，通知消费者线程继续工作。
条件变量的作用：确保消费者线程只在有足够数据（即两个相机的数据都到达）时才会继续进行同步处理，防止不匹配的数据被处理。

生产者-消费者模型：两个生产者线程（相机1和相机2）不断产生数据，并将数据放入各自的队列中。消费者线程（timestampComparator）则对两个相机的时间戳进行比对。
- 每个相机的生产者线程使用信号量来控制生产的节奏，避免缓冲区溢出。
- 消费者线程通过条件变量同步，确保在两个相机的数据到达后，才会进行时间戳比较。
互斥锁：所有线程在访问共享的队列时都需要上锁，避免竞争条件（race conditions）。在操作队列时，使用 std::unique_lock<std::mutex> 来确保互斥访问。