导航:首页 > 编程系统 > linux队列实现

linux队列实现

发布时间:2024-10-06 22:07:20

⑴ 请教一个关于linux消息队列的问题

一般使用步骤:

1. 用ftok产生一个key。

2. 调用msgget(使用key作为参数)产生一个队列

3. 进程可以用msgsnd发送消息到这个队列,相应的别的进程用msgrcv读取。

这里需要注意msgsnd可能会失败的两个情况:

a) 可能被中断打断(包括msgsnd和msgrcv). 尤其是大流量应用中更容易出现. 比较安全的用法是判断操作是否被中断打断,如果被打断, 则需要继续尝试。

b) 消息队列满。产生这个错误,则需要考虑提高系统消息队列规格,或者查看消息接收处是否有问题

4. msgctl函数可以用来删除消息队列
消息队列产生之后,除非明确的删除(可以用),产生的队列会一直保留在系统中。linux下消息队列的个数是有限的,注意不要泄露。如果 使用已经达到上限,msgget调用会失败,产生的错误码对应的提示信息为no space left on device.

注意点:

1.消息的类型 mtype 不需为非0值。如果使用0,则msgsnd会失败,并得到”Invalid argument“错误。

2.msgflg为0表示阻塞等待,如果msgflg为IPC_NOWAIT表示非阻塞。

3.最好使用root权限执行消息队列,否则msgrcv 提示 "Permission denied"。

⑵ linux内核工作队列怎么工作的

Linux 2.6内核使用了不少工作队列来处理任务,他在使用上和 tasklet最大的不同是工作队列的函数可以使用休眠,而tasklet的函数是不允许使用休眠的。
工作队列的使用又分两种情况,一种是利用系统共享的工作队列来添加自己的工作,这种情况处理函数不能消耗太多时间,这样会影响共享队列中其他任务的处理;另外一种是创建自己的工作队列并添加工作。

(一)利用系统共享的工作队列添加工作:

第一步:声明或编写一个工作处理函数
void my_func();
第二步:创建一个工作结构体变量,并将处理函数和参数的入口地址赋给这个工作结构体变量
DECLARE_WORK(my_work,my_func,&data); //编译时创建名为my_work的结构体变量并把函数入口地址和参数地址赋给它;
如果不想要在编译时就用DECLARE_WORK()创建并初始化工作结构体变量,也可以在程序运行时再用INIT_WORK()创建
struct work_struct my_work; //创建一个名为my_work的结构体变量,创建后才能使用INIT_WORK()
INIT_WORK(&my_work,my_func,&data); //初始化已经创建的my_work,其实就是往这个结构体变量中添加处理函数的入口地址和data的地址,通常在驱动的open函数中完成
第三步:将工作结构体变量添加入系统的共享工作队列
schele_work(&my_work); //添加入队列的工作完成后会自动从队列中删除
或schele_delayed_work(&my_work,tick); //延时tick个滴答后再提交工作
(二)创建自己的工作队列来添加工作
第一步:声明工作处理函数和一个指向工作队列的指针
void my_func();
struct workqueue_struct *p_queue;
第二步:创建自己的工作队列和工作结构体变量(通常在open函数中完成)
p_queu=create_workqueue("my_queue"); //创建一个名为my_queue的工作队列并把工作队列的入口地址赋给声明的指针
struct work_struct my_work;
INIT_WORK(&my_work, my_func, &data); //创建一个工作结构体变量并初始化,和第一种情况的方法一样
第三步:将工作添加入自己创建的工作队列等待执行
queue_work(p_queue, &my_work);
//作用与schele_work()类似,不同的是将工作添加入p_queue指针指向的工作队列而不是系统共享的工作队列
第四步:删除自己的工作队列
destroy_workqueue(p_queue); //一般是在close函数中删除

⑶ 如何用JAVA实现Linux上的消息队列功能

下面来说说如何用不用消息队列来进行进程间的通信,消息队列与命名管回道有很多相似之处。有关命答名管道的更多内容可以参阅我的另一篇文章:Linux进程间通信——使用命名管道 一、什么是消息队列 消息队列提供了一种从一个进程向另一个进程发送一个数

⑷ linux 进程通信方式 pipe无名管道 fifo有名管道 共享内存映射 socket 消息队列

在Linux系统中,进程间的通信(IPC, Inter-Process Communication)主要通过四种机制实现:管道(pipe)、有名管道(fifo)、共享内存映射以及Unix域socket。这些方法各自适用于不同的场景,让进程能够有效地交换数据。


1. 管道(pipe):无名管道,由`pipe()`函数创建,适合于有血缘关系的进程间通信,如父子进程。它在内核中创建一个缓冲区,通过`filedes`参数传递给用户进程,用于单向通信,数据写满后会阻塞。


2. 有名管道(fifo):解决无血缘关系进程间的通信,使用`mkfifo`创建,相当于磁盘上的一个文件,通过文件名访问。它实质上是基于管道的,只是给管道起了个名字,读写需要进程都打开文件。


3. 共享内存映射(mmap):通过`mmap`函数将磁盘文件的一部分映射到内存,支持同步修改(share映射)和独立修改(private映射)。这常用于进程间的数据传递,特别是权限受限的情况下。


4. Unix域socket(socket):利用网络通信技术,适用于远程进程间的通信,常用于服务器-客户端模型,数据按照协议解析。


消息队列,虽然视频中未提及,但它是另一种间接通信方式,类似于邮箱系统,接收方根据消息类型从中间体获取信息。消息队列提供了一种独立于进程运行状态的通信方式,写入者无需关心接收者是否在读取。


每种方法都有其优缺点,选择哪种取决于具体的应用场景和性能需求。理解这些通信方式有助于编写高效、可靠的多进程应用程序。

阅读全文

与linux队列实现相关的资料

热点内容
电脑上有哪些弹钢琴的app 浏览:279
vegas英文版教程 浏览:757
vs怎么输入数据后显示结果 浏览:253
plc编程证书去哪里报名 浏览:262
如何登录下载尚德教育官方网站 浏览:298
微信老版本50安卓下载 浏览:269
jslocationhref参数 浏览:845
java假设检验 浏览:98
js多文件下载 浏览:467
编程培训需要什么学历 浏览:65
hibernate需要数据库设置外键吗 浏览:184
linux队列实现 浏览:706
java常量对象 浏览:126
javacdi 浏览:946
女人为什么都喜欢苹果 浏览:254
用文本文档写搞笑代码 浏览:858
项目文件整理属于什么 浏览:977
模具编程怎样分析用什么策略 浏览:193
java下载文件重命名 浏览:388
有什么app可以看图纸 浏览:504

友情链接