当前位置: 技术问答>linux和unix
请教各位大虾一个关于进程间通信的程序问题!
来源: 互联网 发布时间:2016-02-08
本文导语: 请问各位大虾,小的有礼了!! 本人想实现这样一个例子,以main()函数为主线程,在主线程中创建一个子线程,该子线程监控udp端口,当发现有udp消息时则向主线程发送一个触发消息,主线程接...
请问各位大虾,小的有礼了!!
本人想实现这样一个例子,以main()函数为主线程,在主线程中创建一个子线程,该子线程监控udp端口,当发现有udp消息时则向主线程发送一个触发消息,主线程接到消息后就作相应的处理,小的无法实现这样的功能,请教各位大虾了!多谢!大虾们写个基本的流程给小的看看都可以!
本人想实现这样一个例子,以main()函数为主线程,在主线程中创建一个子线程,该子线程监控udp端口,当发现有udp消息时则向主线程发送一个触发消息,主线程接到消息后就作相应的处理,小的无法实现这样的功能,请教各位大虾了!多谢!大虾们写个基本的流程给小的看看都可以!
|
“子线程监控udp端口,当发现有udp消息时则向主线程发送一个触发消息,主线程接到消息后就作相应的处理”
你这样的设计实际上是主线程与子线程都在监控,子线程监控UDP,主线程监控子线程是否发送回消息,感觉这样设计不合理,也有点多此一举。
你可以让子线程监控,发现有udp消息则直接调用主线程的函数处理,或者干脆自己直接处理,不用让主线程也阻塞。
或者直接让主线程监听udp端口,发现有消息直接处理。
------------------------------------
如果你非要让子线程监听,然后再通知主线程,这就是线程间通信问题,大概有以下方法:
1. 信号量。 主线程阻塞于某信号量,直到子线程监听到udp消息,释放信号量,相关函数pthread_mutex_init,
pthread_mutex_lock, pthread_mutex_unlock.
2. 全局变量。 主线程阻塞于select或者poll,监听一个全局变量是否改变,子线程监听到udp消息,修改这个全局变量,触发主线程。
3. 本地socket。 再建一个本地socket,主线程阻塞与监听这个本地socket,子线程监听到udp消息,向这个本地socket发送消息,触发主线程。
还有很多,比如管道,消息队列等等等等。
你这样的设计实际上是主线程与子线程都在监控,子线程监控UDP,主线程监控子线程是否发送回消息,感觉这样设计不合理,也有点多此一举。
你可以让子线程监控,发现有udp消息则直接调用主线程的函数处理,或者干脆自己直接处理,不用让主线程也阻塞。
或者直接让主线程监听udp端口,发现有消息直接处理。
------------------------------------
如果你非要让子线程监听,然后再通知主线程,这就是线程间通信问题,大概有以下方法:
1. 信号量。 主线程阻塞于某信号量,直到子线程监听到udp消息,释放信号量,相关函数pthread_mutex_init,
pthread_mutex_lock, pthread_mutex_unlock.
2. 全局变量。 主线程阻塞于select或者poll,监听一个全局变量是否改变,子线程监听到udp消息,修改这个全局变量,触发主线程。
3. 本地socket。 再建一个本地socket,主线程阻塞与监听这个本地socket,子线程监听到udp消息,向这个本地socket发送消息,触发主线程。
还有很多,比如管道,消息队列等等等等。
|
这样可以不,主线程用子线程间用消息队列传递消息
main()
{
pthread_t thread_udp_monitor = pthread_create(,fun,);
readform msg_queue;
}
fun()
{
int fd = socket(AF_INET, DATAGRAM, 0)
bind (fd, port )
time_t timeout;
fread a;
bzero()
fset()
res = select(fd + 1, &a, NULL, NULL, &timeout);
if(res)
{
send_msg_queue;
}
}
main()
{
pthread_t thread_udp_monitor = pthread_create(,fun,);
readform msg_queue;
}
fun()
{
int fd = socket(AF_INET, DATAGRAM, 0)
bind (fd, port )
time_t timeout;
fread a;
bzero()
fset()
res = select(fd + 1, &a, NULL, NULL, &timeout);
if(res)
{
send_msg_queue;
}
}