当我这样做时:
myProgram.h
myProgram.c
struct PipeShm
{
// all my fields
// more
// ...
};
struct PipeShm myPipe = { /* initialization for all fields */ };
struct PipeShm * sharedPipe = &myPipe;
void func()
{
sharedPipe = mmap (NULL, sizeof * sharedPipe, PROT_READ | PROT_WRITE,MAP_SHARED | MAP_ANONYMOUS, -1, 0);
}
当我 mmap 指针 sharedPipe 时,如果我从 main() 调用 myProgram 代码中的任何方法,是否所有进程都共享我与 myPipe 结构共享的确切共享内存?
或者每个新创建的 child 都会有一个属于他自己的新 myPipe 吗?
问候
编辑:
这是在我阅读评论和答案之后:现在进行了更改,并且我仅在分配段后才初始化该段的值:
#include "my_pipe.h"
struct PipeShm * sharedPipe = NULL;
int shm_pipe_init()
{
if (!sharedPipe)
{
int myFd = shm_open ("/myregion", O_CREAT | O_TRUNC | O_RDWR, 0600);
if (myFd == -1)
error_out ("shm_open");
// Allocate some memory in the region - We use ftruncate, write(2) would work just as well
int retAlloc = ftruncate (myFd, sizeof * sharedPipe);
if (retAlloc < 0)
error_out("ftruncate");
sharedPipe = mmap (NULL, sizeof * sharedPipe,
PROT_READ | PROT_WRITE,MAP_SHARED | MAP_ANONYMOUS, myFd, 0);
if (!sem_init (&sharedPipe->semaphore, 1, 0))
{
sharedPipe->init = TRUE;
sharedPipe->flag = FALSE;
sharedPipe->ptr1 = NULL;
sharedPipe->ptr2 = NULL;
sharedPipe->status1 = -10;
sharedPipe->status2 = -10;
sharedPipe->semaphoreFlag = FALSE;
sharedPipe->currentPipeIndex = 0;
}
else
perror ("shm_pipe_init");
}
return 1; // always successful
}
但是问题仍然存在,共享内存似乎没有在进程之间共享,因为在运行和 fork 该 main 时:
int main()
{
int spd, pid, rb;
char buff[4096];
fork();
shm_pipe_init();
// more
return 0;
}
我仍然得到输出,它模拟了只有一个进程在运行的行为(而不是多个输出,我只得到一个一个或一个一对,取决于进程之间的竞争条件)。
最佳答案
如果您打算多次调用此程序,答案是否定的。如果您打算在创建映射后进行 fork ,答案是"is"。
匿名映射没有底层文件。因此,创建匿名映射的进程无法指定它特别需要哪个已经存在的映射(这也不是预期的用途,您应该获得一个新的、独立的映射)。因此对第一种情况说“不”。
共享映射允许拥有相同映射的所有进程访问相同的物理内存。这意味着,如果您在创建映射后 fork,那么 fork 将主要以通常的方式工作,将进程拥有的所有页面标记为写时复制 除了映射中的页面。父项和子项都将保留映射的页面,并且能够通过指针访问相同的物理内存(顺便说一句,这意味着页面甚至也将具有相同的虚拟地址——这在映射文件时通常不是您可以依赖的东西,但在这种情况下,操作系统别无选择,只能确保是这种情况。
联机帮助页对匿名映射和共享映射的组合或确切应该发生的事情仍然含糊不清,但 TLPI 第 49.7 章明确提到 MAP_SHARED|MAP_ANONYMOUS:
[...] followed by a call to fork(), then, because the child produced by fork() inherits the mapping, both processes share the memory region.
因此第二种情况为"is"。
回复:编辑后的帖子
错误的顺序:
fork();
shm_pipe_init();
这会首先 fork ,然后初始化共享内存。这只会创建一个共享(读作 share-able,如果进程再次 fork ,它可能会在未来共享,但它不会神奇地与父级反向共享!)映射 对于每个进程,分别。
然后你有两个映射,每个进程一个,它们将由它们各自的子进程和孙进程(如果有的话)共享,但这对实现你想要的没有任何帮助。它们是“共享”的事实并不重要,它们是不同的映射,并且对各自的其他进程是未知的。
首先创建映射,然后 fork 。这将创建一个共享映射,两个进程确实拥有/共享并且可以用于预期目的。
(此外,您对 fork 的用法严格来说并没有错,但有点奇怪...您通常应该检查返回值,这样您就知道哪个是父级,哪个是父级一个是 child 。这不像 fork 不会失败。当然,如果这根本不重要,因为 parent 和 child 总是 100% 相同,你不关心失败,没关系。不过通常情况下,人们通常想知道。)
关于c - mmap 是否与所有进程共享内存?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11738703/
作为我的Rails应用程序的一部分,我编写了一个小导入程序,它从我们的LDAP系统中吸取数据并将其塞入一个用户表中。不幸的是,与LDAP相关的代码在遍历我们的32K用户时泄漏了大量内存,我一直无法弄清楚如何解决这个问题。这个问题似乎在某种程度上与LDAP库有关,因为当我删除对LDAP内容的调用时,内存使用情况会很好地稳定下来。此外,不断增加的对象是Net::BER::BerIdentifiedString和Net::BER::BerIdentifiedArray,它们都是LDAP库的一部分。当我运行导入时,内存使用量最终达到超过1GB的峰值。如果问题存在,我需要找到一些方法来更正我的代
给定这段代码defcreate@upgrades=User.update_all(["role=?","upgraded"],:id=>params[:upgrade])redirect_toadmin_upgrades_path,:notice=>"Successfullyupgradeduser."end我如何在该操作中实际验证它们是否已保存或未重定向到适当的页面和消息? 最佳答案 在Rails3中,update_all不返回任何有意义的信息,除了已更新的记录数(这可能取决于您的DBMS是否返回该信息)。http://ar.ru
我试图获取一个长度在1到10之间的字符串,并输出将字符串分解为大小为1、2或3的连续子字符串的所有可能方式。例如:输入:123456将整数分割成单个字符,然后继续查找组合。该代码将返回以下所有数组。[1,2,3,4,5,6][12,3,4,5,6][1,23,4,5,6][1,2,34,5,6][1,2,3,45,6][1,2,3,4,56][12,34,5,6][12,3,45,6][12,3,4,56][1,23,45,6][1,2,34,56][1,23,4,56][12,34,56][123,4,5,6][1,234,5,6][1,2,345,6][1,2,3,456][123
在MRIRuby中我可以这样做:deftransferinternal_server=self.init_serverpid=forkdointernal_server.runend#Maketheserverprocessrunindependently.Process.detach(pid)internal_client=self.init_client#Dootherstuffwithconnectingtointernal_server...internal_client.post('somedata')ensure#KillserverProcess.kill('KILL',
这个问题在这里已经有了答案:Checktoseeifanarrayisalreadysorted?(8个答案)关闭9年前。我只是想知道是否有办法检查数组是否在增加?这是我的解决方案,但我正在寻找更漂亮的方法:n=-1@arr.flatten.each{|e|returnfalseife
我正在编写一个gem,我必须在其中fork两个启动两个webrick服务器的进程。我想通过基类的类方法启动这个服务器,因为应该只有这两个服务器在运行,而不是多个。在运行时,我想调用这两个服务器上的一些方法来更改变量。我的问题是,我无法通过基类的类方法访问fork的实例变量。此外,我不能在我的基类中使用线程,因为在幕后我正在使用另一个不是线程安全的库。所以我必须将每个服务器派生到它自己的进程。我用类变量试过了,比如@@server。但是当我试图通过基类访问这个变量时,它是nil。我读到在Ruby中不可能在分支之间共享类变量,对吗?那么,还有其他解决办法吗?我考虑过使用单例,但我不确定这是
当我的预订模型通过rake任务在状态机上转换时,我试图找出如何跳过对ActiveRecord对象的特定实例的验证。我想在reservation.close时跳过所有验证!叫做。希望调用reservation.close!(:validate=>false)之类的东西。仅供引用,我们正在使用https://github.com/pluginaweek/state_machine用于状态机。这是我的预订模型的示例。classReservation["requested","negotiating","approved"])}state_machine:initial=>'requested
我有这个html标记:我想得到这个:我如何使用Nokogiri做到这一点? 最佳答案 require'nokogiri'doc=Nokogiri::HTML('')您可以通过xpath删除所有属性:doc.xpath('//@*').remove或者,如果您需要做一些更复杂的事情,有时使用以下方法遍历所有元素会更容易:doc.traversedo|node|node.keys.eachdo|attribute|node.deleteattributeendend 关于ruby-Nokog
我有一个包含多个键的散列和一个字符串,该字符串不包含散列中的任何键或包含一个键。h={"k1"=>"v1","k2"=>"v2","k3"=>"v3"}s="thisisanexamplestringthatmightoccurwithakeysomewhereinthestringk1(withspecialcharacterslike(^&*$#@!^&&*))"检查s是否包含h中的任何键的最佳方法是什么,如果包含,则返回它包含的键的值?例如,对于上面的h和s的例子,输出应该是v1。编辑:只有字符串是用户定义的。哈希将始终相同。 最佳答案
我需要检查DateTime是否采用有效的ISO8601格式。喜欢:#iso8601?我检查了ruby是否有特定方法,但没有找到。目前我正在使用date.iso8601==date来检查这个。有什么好的方法吗?编辑解释我的环境,并改变问题的范围。因此,我的项目将使用jsapiFullCalendar,这就是我需要iso8601字符串格式的原因。我想知道更好或正确的方法是什么,以正确的格式将日期保存在数据库中,或者让ActiveRecord完成它们的工作并在我需要时间信息时对其进行操作。 最佳答案 我不太明白你的问题。我假设您想检查