multiprocessing相关内容

分割工作,多个线程需要更多的时间,为什么呢?

我有一个计算小的C程序的 PI 的使用 monte-卡罗 -simulation这基本上只是测试了一个随机点[X,Y]如果它是内部还是一个圈子之外。 要逼近的 PI 的我必须使用大量的样本的 N 的有直接正比复杂的 O(N)的。因此,试图到n计算样本数量巨大,我实现了 POSIX线程 API来parallize的计算能力 我的code是这样的: 的pthread_t工人[确定nthreads ..
发布时间:2016-08-23 10:12:17 C/C++

如何设置优先获得在C / C互斥++

我有3个过程(相同的优先级) P1 P2 P3(定时器) 优先获得互斥如下: P1(1优先级),P2(2优先级),P3(定时器)(3优先级) 如果假设 P3 来,并得到互斥 那么 P2 来,等待互斥 之后P1来得快,也等待互斥 如果 P3 释放互斥然后 P1 应该得到互斥不是 P2 。 如何用C或C ++,执行此 请注意:所有进程都具有内相同优先级的线程运行 操作系统 ..
发布时间:2016-08-21 22:41:46 C/C++开发

为什么没有这个code线的规模?

我写这SOR求解code。不要打扰太多这种算法做什么,这是不是这里的关注。但只是为了完整起见:它可以解决线性方程系统,根据系统是如何调节 我用病态的2097152行sparce矩阵(从不收敛)运行,每行最多7个非零列。 翻译:外做的,而循环将执行10000次迭代(我通过为 max_iters值),中间为将进行2097152迭代,劈 work_line 的块,OpenMP的线程分割。最里面的为循 ..
发布时间:2016-08-21 20:08:57 C/C++

C / C ++ Linux的fork()和EXEC()

我使用fork()创建子进程。从子进程我使用EXEC()来启动新的进程。我的code如下: ...... PID =叉(); 如果(PID大于0){ WRITELOG(“父进程”); //做一点事 }如果别人(PID == 0){ WRITELOG(“子进程”); int返回= EXECL(shellscript里); ..
发布时间:2016-08-19 14:21:17 服务器开发

多个fork()的并发

如何在这样你可以生成10个进程,并让他们做一个小任务并行的方式使用fork()的命令。 并发是最关键的词,很多地方显示如何使用fork只使用()在他们的演示一个调用叉。我以为你会用某种形式的for循环,但我想,它似乎在我的测试,该叉()'s的产卵一个新的进程,做的工作,然后生成一个新的进程。因此,他们似乎正在运行顺序,但我怎么能同时叉,并有10个进程同时做的工作如果是有道理的? 感谢。 更新 ..
发布时间:2016-08-18 22:30:58 服务器开发

在内存静态和全局变量

是否存储类似于全局栈本身的静态变量?如果是这样,他们如何保护,只允许本地级接入? 在一个多线程上下文是,该存储器可以被其他线程/内核直接访问的恐惧?或为什么不能使用静态/全球多进程/线程enviornment? 解决方案 存储在堆栈上的变量在本质上的时间。他们属于一个功能等,当函数返回和相应的堆栈帧被弹出,堆栈变量与它消失。由于全局被设计成访问无处不在,它们必须不出去上下文,并因此被 ..
发布时间:2016-08-18 14:29:12 C/C++开发

是否有等待()系统调用设置一个超时的版本?

有没有办法使用的wait()系统调用超时,除了使用忙等待或忙睡眠循环? 我已经得到了叉父进程取值本身和 EXEC 是个孩子的可执行文件。然后等待孩子来完成,通过一切适当手段抓住它的输出,以及并进行进一步处理。如果该过程不的一段时间内完成,则认为其执行超时,并执行别的东西。不幸的是,这个超时检测是必要的,因为该问题的性质 解决方案 有不等待调用了超时。 你可以做的,而不是为安装设置SIG ..
发布时间:2016-08-18 13:37:12 服务器开发

Python的使用多个处理器

可以说我有不同的长度需要转换或不同的需要进行调整或类似的东西大小的图像,音乐的大名单。顺序并不重要,因此非常适合跨多个处理器分裂。 如果我用multiprocessing.Pool的地图功能,好像所有的工作被分割的时间提前,并没有考虑到的是,有些文件可能需要更长的时间做别人。 什么情况是,如果我有12个处理器...附近处理结束,1或2处理器将有2个或3个文件留下来处理而也可以使用其它的处理器处 ..
发布时间:2016-08-04 17:32:36 Python

编程执行和终止在蟒蛇长时间运行的批处理

我一直在寻找一种方式来启动和终止蟒长期运行的“批处理作业”。现在,我使用“使用os.system()”推出了长时间运行的批处理作业中的每个子进程中。正如你可能已经猜到了,“使用os.system()”派生的子进程(孙进程吗?)内的新的进程,所以我不能杀了从盛大父进程批处理作业。为了提供我刚才所描述的一些可视化: 主(祖父母)工艺,具有PID = AAAA | ..
发布时间:2016-08-04 16:55:13 Python

使用屏幕和Bash多

在不同的节点在学校使用SSH运行python脚本。每个节点有8个内核。我使用GNU屏幕,可以从一个单一的过程中脱落。 是更可取的: 运行屏幕的几个不同的会话。 运行一个屏幕过程,并使用&功放;在bash终端。 他们是否相同呢? 我不知道如果我的实验是很差codeD,并采取过多的时间量(很可能),或者我选择使用1是跌大大减慢的过程。谢谢! 解决方案 通过庆典我想像你正在做这 ..
发布时间:2016-08-03 11:06:38 Python

如何写一个程序池的bash shell

我有10个以上的任务来执行,并且系统限制存在至多4个任务可以同时运行。 我的任务就可以开始,如: MYPROG TASKNAME 我怎么能写一个bash shell脚本来运行这些任务。最重要的是,当一个任务完成,脚本就可以立即开始另一个,使得正在运行的任务依然计数4所有的时间。 解决方案 我偶然发现这个线程,同时寻找到写我自己的进程池和特别喜欢布兰登霍斯利的解决方案,但我不能让信号工 ..
发布时间:2016-08-02 14:34:26 Linux/Unix

从previous处理多个变量的awk处理?

我有问答的awk的处理,我有以下文件 猫的test.txt /家庭/嘘/ abc.c /家庭/嘘/ 2 / def.c gthjrjrdj.c /内核/上水屠房 sarawtera.c wrawrt.h wearwaerw.h 我的目标是使从拆分句子完整路径 /home/jhyoon/abc.c 。 这是我从别人得到了命令:猫的test.txt | AWK'/^\\/.*/{path=$ ..
发布时间:2016-07-29 11:13:27 Linux/Unix

异步从进程中检索信息

下面是伪code什么我想要做的。 导入时间高清的run(): 而X'LT; 10000000: X + = 1如果__name__ ==“__main__”: P =过程(运行) p.start() time.sleep(3) #some code,我不知道会给我x的当前值 蟒蛇线程模块似乎但是去我还没有成功地实现这个例子的方式。 解决方案 ..
发布时间:2016-07-21 10:35:19 Python

了解异步/多处理在Python

可以说我有一个函数: 不时进口睡眠高清doSomethingThatTakesALongTime(数): 打印张数 睡眠(10) 然后我把它称为一个for循环有效范围内(10)号: doSomethingThatTakesALongTime(数) 我 如何进行此项设置,使其只需要10秒TOTAL打印出来: $为0123456789 而不是采取100秒。如果有帮助,我将使用您 ..
发布时间:2016-07-21 10:34:43 Python

使用Python的multiprocessing.pool.map操纵相同的整数

问题 我使用Python的多模块异步执行的功能。我想要做的是能够跟踪我的剧本的全面进步,因为每个进程调用并执行 DEF add_print 。举例来说,我想code以下加1 总并打印出值( 1 2 3 ... 18 19 20 )每次进程运行该功能。我第一次尝试是使用全局变量,但这并没有工作。由于该功能被异步调用的,每一个进程读总 0,以开始,并独立加1其他进程。所以输出是20的递增值,而不是 ..

发送和Python中接收异步过multiprocessing.Pipe()

我有一些问题得到Pipe.send在这个code工作。我最终会做的是发送和接收消息,并从国外进程,而其在运行叉。这最终将要被集成到一个Pexpect的循环为交谈间preTER流程。 从多处理导入过程中,管 从进口Pexpect的产卵 类CockProc(进程): 高清启动(个体经营): self.process =产卵('coqtop',['-emacs-U']) D ..
发布时间:2016-07-21 10:14:20 Python

什么样的问题(如果有的话)会有多处理相结合ASYNCIO?

由于几乎每个人都知道当他们第一次看到在Python线程,也使得生活悲惨的究竟是谁想要做处理并行人GIL - 或者至少给它一个机会。 我目前正在寻求实现像反应堆模式。有效地我要听传入套接字连接在一个线状,当有人试图连接,接受连接,并把它传递到另一个线程类进行处理。 我(还)没有肯定,我可能会面临什么样的负载。我知道有目前的设置对传入邮件2MB的上限。从理论上讲,我们可以得到每秒数千次(虽然我不知 ..

Python的多处理过程或池为我在做什么?

我是新的Python多处理和试图找出我是否应该使用池或过程调用两个功能异步。这两个函数我必须做出卷曲电话和解析信息到2个独立的名单。根据不同的互联网连接,各功能可以采取每个约4秒。我意识到,瓶颈是在ISP连接和多不加快步伐了,但它会是不错的他们俩揭开序幕异步。另外,这对我来说是进入python的多任务处理,因为我将更加以后使用它一个很好的学习经验。 我读 ..
发布时间:2016-07-21 09:35:15 Python