linux 两个线程 等待输入
在Linux系统中，多个线程等待输入的情况通常涉及到多线程编程和同步机制。以下是对这个问题的详细解答：
基础概念
线程：线程是操作系统能够进行运算调度的最小单位，它被包含在进程之中，是进程中的实际运作单位。
等待输入：指的是线程在执行过程中需要暂停，直到接收到外部输入（如键盘输入、文件描述符上的数据到达等）后再继续执行。
同步机制：为了保证多线程程序的正确性，需要使用同步机制来协调不同线程之间的执行顺序和访问共享资源的时机。
相关优势
- 提高效率：多个线程可以并行处理任务，从而提高程序的整体执行效率。
- 响应性：当某个线程在等待输入时，其他线程可以继续执行其他任务，从而保持程序的响应性。
类型与应用场景
类型：
- 阻塞式等待：线程在等待输入时会进入阻塞状态，直到输入到达。
- 非阻塞式等待：线程会定期检查输入是否可用，而不是一直等待。
应用场景：
- 并发服务器：处理多个客户端请求时，可以使用多个线程分别等待不同客户端的输入。
- 实时系统：需要在等待输入的同时执行其他紧急任务的场景。
遇到的问题及原因
问题：两个线程同时等待输入时，可能会出现竞争条件或不必要的等待。
原因：
- 资源争用：多个线程试图访问同一输入源可能导致数据不一致或冲突。
- 效率低下：如果一个线程长时间等待输入，而另一个线程空闲，会造成资源浪费。
解决方法
使用互斥锁（Mutex）
互斥锁可以确保同一时间只有一个线程访问输入源。
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
int input_ready = 0;
void* thread_func(void* arg) {
while (1) {
pthread_mutex_lock(&mutex);
if (input_ready) {
// 处理输入
input_ready = 0;
pthread_mutex_unlock(&mutex);
break;
}
pthread_mutex_unlock(&mutex);
// 可以在这里执行其他任务
}
return NULL;
}
int main() {
pthread_t thread1, thread2;
pthread_create(&thread1, NULL, thread_func, NULL);
pthread_create(&thread2, NULL, thread_func, NULL);
// 模拟输入到达
pthread_mutex_lock(&mutex);
input_ready = 1;
pthread_mutex_unlock(&mutex);
pthread_join(thread1, NULL);
pthread_join(thread2, NULL);
return 0;
}使用条件变量（Condition Variable）
条件变量允许线程在特定条件满足时被唤醒。
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
int input_ready = 0;
void* thread_func(void* arg) {
pthread_mutex_lock(&mutex);
while (!input_ready) {
pthread_cond_wait(&cond, &mutex);
}
// 处理输入
input_ready = 0;
pthread_mutex_unlock(&mutex);
return NULL;
}
int main() {
pthread_t thread1, thread2;
pthread_create(&thread1, NULL, thread_func, NULL);
pthread_create(&thread2, NULL, thread_func, NULL);
// 模拟输入到达
pthread_mutex_lock(&mutex);
input_ready = 1;
pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
pthread_join(thread1, NULL);
pthread_join(thread2, NULL);
return 0;
}通过使用互斥锁和条件变量，可以有效管理多个线程等待输入的情况，避免竞争条件和提高程序效率。
相关·内容
此线程的设计使其能够通过WaitForMultipleObjects对两个事件进行等待：
在Windows下，这个线程进入一个主循环，在其中它为这两个事件的Wait( bWaitAll是FALSE)。等待stdin句柄有信号传递的效果，当输入准备好要读取时，另一个事件从应用程序的其他位置
浏览 1提问于2012-11-06得票数 4
6回答
我们正在创建一个点对点程序(在c中)，并且我们使用了多个线程，这样程序就可以监听新的连接并接收/发送数据。问题是，我记得我的教授告诉我们，如果你有多个线程在同一个进程上运行，如果一个线程必须等待用户输入，整个进程就会“暂停”，所以其他线程都不会继续运行。但是我们一直在阅读，似乎如果一个线程在等待输入，其他线程就会像往常一样运行。
哪一个是对的？如果我们让程序在一个线程上等待</em
浏览 1提问于2011-11-28得票数 2
回答已采纳
1回答
在此期间，用户可以使用getch()进行输入，也可以不使用。
我该如何编写这样的程序？这就是我能为你们提供的东西。
浏览 0提问于2014-03-04得票数 0
我有一个类，它执行一个线程，以便不断地从给定的istream中读取行，然后在内部进行解析。在某种程度上，我希望它能够结束，但是由于getline()调用是阻塞的，它可能会在join()上永远等待。如果是C我就会杀了线程..。
浏览 3提问于2021-06-26得票数 4
回答已采纳
在Linux中，我有这样一个场景:两个线程执行一个临界区，一个线程获取锁(线程A)，另一个线程(线程B)等待锁。稍后，threadA释放互斥锁。threadB进入等待( TASK_INTERRUPTABLE )状态(在互斥锁被阻塞，因此处于等待状态)，当threadA解锁互斥锁时，它会收到信号，因此它会返回到运行队列(TASK_RUNNING)
浏览 76提问于2020-12-30得票数 0
在客户端程序中，我创建两个线程(使用Python的线程模块)，一个用于接收，一个用于发送。接收线程不断从服务器端接收字符串；而发送线程不断侦听用户输入(使用raw_input())并将其发送到服务器端。这两个线程使用一个队列进行通信(这个队列本身就是同步的，比如！)。这里的问题是，在大多数情况下，发送线程会被"raw_input()“阻塞，并等待用户输入。当它被阻塞时，从另一个线程
浏览 1提问于2014-09-22得票数 7
回答已采纳
我使用python2.7和模块线程。现在我有一个24小时倒计时，这是一个线程，另一个线程是接受用户输入使用原始输入。当我的程序运行时，倒计时线程正在等待用户输入被插入，只有这样倒计时才会继续。首先，我使用线程是为了实现两个线程同时运行。我只是不明白为什么一个线程会等待另一个线程的输入？以及如何解决这个问题？提前感谢！
浏览 1提问于2017-04-09得票数 0
回答已采纳
2回答
我使用python脚本在linux上接收输入并运行命令。在线程中接收到一个命令，它分解一个逻辑卷。但有时要花很长时间才能完成磁盘逻辑卷的分解。subproc.Popen('shred /dev/group/m1')
python中的线程一次运行一个。因此，脚本挂起，在运行子进程时不接受其他输入。有没有办法解决这个问题，以便在线程等待来自stdout的数据时可以同时处理其他输入？
浏览 2提问于2014-03-08得票数 0
假设我们有父线程Tp，它以相同的顺序启动两个子线程Tc1和Tc2，并等待Tc2加入(Tc2.join())。现在的问题是父线程仍然处于等待Tc2加入的状态，并且进程仍然挂起。Tc1如何终止Tc2 (处于用户输入等待<
浏览 0提问于2020-10-08得票数 0
回答已采纳
2回答
我有一个事件处理代码，为我的触摸屏读取Linux的/dev/ that /，并打印结果，然后按下/释放哪个按钮。int main(int argc, char** argv)
浏览 0提问于2018-09-08得票数 0
回答已采纳
1回答
在我的应用程序中，主线程创建了两个连接的线程；一个线程通过在循环中调用scanf()来等待用户输入，另一个线程通过在循环中调用accept()来侦听传入的套接字连接。新连接在分离的单独线程中处理。这意味着侦听线程应该停止接受新的连接，等待当前服务连接的线程关闭，然后。等待用户输入的线程也应该结束，从而允许主线程结束。Scanf(
浏览 1提问于2012-01-30得票数 5
回答已采纳
我正试图使用消息队列和线程在Linux中编写一个信使程序。user1) ./msg 1234 4321 // snd_key: 1234, rcv_key: 4321
然后创建两个消息队列:一个用于发送，另一个用于接收消息。然后启动一个线程来运行发送方()，以类似的方式传入&snd_queue作为参数和接收者。然后，我使用pthread_joing等待两个子线程，然后释放<em
浏览 8提问于2020-04-06得票数 0
有没有办法将数据从一个运行的线程传递到另一个运行的线程。其中一个线程显示一个菜单，用户使用cin选择一个选项。另一个线程正在处理数据并将结果发送到服务器，每隔“X”个时间段。因为我可以在cin指令中等待整个程序等待用户输入数据，所以我将程序分为两个线程。菜单的数据输入在另一个线程中使用。
谢谢
浏览 0提问于2013-05-04得票数 0
1回答
我正在运行一个有一个主线程和一个辅助线程的程序，在满足一定的条件后，这两个线程都应该退出。问题是辅助线程，在检查运行条件仍然有效后，使用std::cin等待用户输入，因此如果在调用std::cin之后满足条件，线程将继续等待用户输入。c; ProcessInput(c);}
因此，当不再满足条件时，两
浏览 1提问于2021-03-16得票数 5
最近，我开始尝试使用std：：线程，我尝试运行一个小程序，该程序在一个单独的线程中显示网络摄像头提要，我正在使用OpenCV。我这样做只是为了“教育”的目的。我注意到，线程似乎一直在内核之间跳来跳去，这让我感到很奇怪，因为我认为从效率/性能的角度来看，这种更改的开销是不值得的。有人知道这种行为的根源/原因吗？
浏览 7提问于2022-07-09得票数 3
回答已采纳
在我尝试用Python学习网络时，我创建了一个简单的服务器-客户机程序。服务器创建一个套接字，并检查连接，然后向所有连接的实体发送一条消息。就像这样，ip=''sock = socket.socket()sock.listen(5)while True: os.system('cls')
浏览 1提问于2015-12-29得票数 1
回答已采纳
3回答
细粒度锁定
、、、、
假设我们有一个很大的数组，并且有许多线程在该数组中的具体索引上操作。两个线程不能同时对一个索引进行操作，其中一个线程应该等待另一个线程完成。还有一个糟糕的问题:如何在Linux/C/C++中对数组的每个索引实现test-and-set锁？
浏览 0提问于2012-01-27得票数 5
我在fedora linux.I中使用的是sqlite3 3.6.23.1版本。我有两个线程正在运行以访问database.There，这两个线程都有可能尝试在同一个表中执行写操作。当第一个线程正在执行写operation.How时，表被锁定。我是否处理这种情况。谢谢&致以问候。
浏览 4提问于2013-06-12得票数 0
1回答
我编写了一个Python脚本，它使用GCC和dockross在Windows和Linux上构建一个应用程序。因为我想加快构建代码的时间，所以我使用线程模块来实现所有四个构建进程(Linux和Windows，32位和64位)。我是否可以在Python中使用任何函数或模块将这两个线程实现为一个耦合线程，当一个线程<
浏览 2提问于2016-12-02得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
