- 正确答案：线程之间的通信方式主要包括共享内存、互斥锁、条件变量、信号量、读写锁、屏障（barrier）、线程局部存储（TLS）、消息队列、管道、信号（signal）以及高级并发库提供的机制（如Java中的wait/notify、Python中的queue等）。其中最核心的方式是基于共享内存配合同步机制实现通信。 - 解答思路：线程属于同一进程，共享进程的地址空间，因此天然可以通过共享变量进行通信。但直接读写共享数据会导致竞态条件（race condition），因此必须配合同步机制来协调线程间的操作顺序。常见的做法是使用互斥锁保护共享数据，结合条件变量实现等待与通知机制。此外，也可以通过操作系统提供的通信机制（如管道、消息队列）或语言层面的并发工具类来实现更高级的通信模式。 - 深度知识讲解： 1. 共享内存（Shared Memory）：线程默认共享堆内存和全局变量，这是线程间通信的基础。例如，一个线程修改某个全局标志位，另一个线程轮询该标志位以判断是否执行某项任务。问题：直接访问共享数据会引发数据竞争。解决方案是引入同步原语。 2. 互斥锁（Mutex）：用于保护临界区，确保同一时间只有一个线程可以访问共享资源。实现原理：通常由操作系统内核支持，底层可能使用原子操作（如CAS、test-and-set）实现。在用户态可能采用futex（Linux）等机制减少系统调用开销。示例代码（C pthread）： pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER; int shared_data = 0; void* thread_func(void* arg) { pthread_mutex_lock(&mtx); shared_data++; pthread_mutex_unlock(&mtx); return NULL; } 3. 条件变量（Condition Variable）：配合互斥锁使用，允许线程等待某个条件成立。常用于生产者-消费者模型。原理：调用wait时自动释放锁并进入等待队列，直到其他线程调用signal或broadcast唤醒。示例代码： pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER; pthread_cond_t cond = PTHREAD_COND_INITIALIZER; int ready = 0; // 等待线程 void* waiter(void* arg) { pthread_mutex_lock(&mtx); while (ready == 0) { pthread_cond_wait(&cond, &mtx); // 自动释放锁并等待 } printf("Notified!\n"); pthread_mutex_unlock(&mtx); return NULL; } // 通知线程 void* notifier(void* arg) { pthread_mutex_lock(&mtx); ready = 1; pthread_cond_signal(&cond); pthread_mutex_unlock(&mtx); return NULL; } 4. 信号量（Semaphore）：计数信号量可用于控制对有限资源的访问，也可用于线程同步。二值信号量等价于互斥锁，计数信号量可用于实现资源池管理。使用sem_init、sem_wait、sem_post等函数。示例：限制最多3个线程同时访问某资源。 sem_t sem; sem_init(&sem, 0, 3); void* worker(void* arg) { sem_wait(&sem); // 访问资源 sleep(1); sem_post(&sem); return NULL; } 5. 读写锁（Read-Write Lock）：允许多个读线程并发访问，但写线程独占。适用于读多写少场景。 pthread_rwlock_t rwlock; 读锁：pthread_rwlock_rdlock() 写锁：pthread_rwlock_wrlock() 6. 屏障（Barrier）：用于多个线程在某个点上同步，所有线程到达后才能继续执行。 pthread_barrier_t barrier; pthread_barrier_init(&barrier, NULL, 3); // 等待3个线程 pthread_barrier_wait(&barrier); 7. 消息队列（Message Queue）：线程间通过发送和接收消息进行通信，解耦生产者与消费者。可以使用标准库如C++的std::queue + mutex + condition_variable，或POSIX消息队列。示例（伪代码）： queue msg_queue; mutex mtx; condition_variable cv; void producer(int id) { for (int i = 0; i < 5; ++i) { unique_lock lock(mtx); msg_queue.push(i); cv.notify_one(); } } void consumer() { while (true) { unique_lock lock(mtx); cv.wait(lock, []{ return !msg_queue.empty(); }); int msg = msg_queue.front(); msg_queue.pop(); lock.unlock(); if (msg == -1) break; cout << "Received: " << msg << endl; } } 8. 管道（Pipe）与命名管道（FIFO）：虽然主要用于进程间通信，但在同一进程的线程中也可使用匿名管道进行单向通信。 Linux中使用pipe()系统调用创建两个文件描述符：fd[0]读端，fd[1]写端。一个线程write，另一个read。 9. 信号（Signal）：线程可以发送信号给其他线程（pthread_kill），但信号处理复杂且易出错，一般不推荐作为主要通信方式。 10. 线程局部存储（TLS）：虽然不是通信方式，但用于避免共享，每个线程有独立副本，通过__thread或thread_local关键字声明。 11. 高级语言封装： Java：synchronized + wait/notify Python：queue.Queue（线程安全队列） Go：goroutine + channel（基于CSP模型） - 扩展知识点： - 内存可见性问题：即使使用了锁，编译器和CPU的优化可能导致变量更新不可见。需要内存屏障（memory barrier）或volatile关键字（在Java中有明确定义，在C/C++中作用有限）。 - happens-before关系：并发编程中定义操作顺序的逻辑基础。 - 无锁编程（lock-free programming）：使用原子操作（如atomic）实现线程通信，避免锁开销。例如CAS（Compare-And-Swap）实现无锁队列。 - ABA问题：在无锁编程中，值从A变为B再变回A，可能导致CAS误判，可用带版本号的原子指针解决。 - 总结：线程通信的本质是在共享内存基础上，通过同步机制协调访问顺序。最基础的是互斥锁+条件变量组合，能实现几乎所有同步需求。实际开发中推荐使用高级抽象如线程安全队列，避免手动管理锁的复杂性。理解底层实现有助于排查死锁、活锁、优先级反转等问题。

小红书秋招java一面

全站热榜

创作者周榜