Python multiprocessing : processes do not start

2019-08-04 03:39发布

I'm new into multiprocessing in Python (2.7).

I try to run the following piece of code:

from time import sleep
from multiprocessing import Process
import multiprocessing

def func(x):
    print("start %s"%(x))
    sleep(x)
    print("end %s"%(x))
    return

if __name__ == '__main__':

    Process(target=func(10)).start()
    Process(target=func(1)).start()

This return something as :

start 10
end 10
start 1
end 1

While start 1 and end 1 should a priori appear before end 10.

I would appreciate help to understand what I might be missing here.

3条回答
贼婆χ
2楼-- · 2019-08-04 04:16

Using Willem Van Onsem answer:

from time import sleep
from multiprocessing import Process
import multiprocessing

def func(x, called_from):
    print("start %s from %s"%(x, called_from))
    sleep(x)
    print("end %s from %s"%(x, called_from))
    return

if __name__ == '__main__':

    Process(target=func, args=(10,'1')).start()
    Process(target=func, args=(1,'2')).start()

You can use a lot of Process more to see when they're called and when they finish. Use other Process calls to see how they work.

查看更多
做自己的国王
3楼-- · 2019-08-04 04:24

You write:

Process(target=func(10)).start()

This means that the Process never is given func, it is given the result of func(10) since Python first evaluates the arguments left-to-right, and then passes the result of these evaluations to the outer function (here the Process(..) call).

In order to let the subprocess evaluate the function, you should write it like:

Process(target=func,args=(10,)).start()

Now you pass a reference to the func function, and you provide a tuple of arguments args with which the sub process is going to call the function. The subprocess will then call func(10) itself (and another subprocess will almost concurrently do the same with func(1)).

查看更多
女痞
4楼-- · 2019-08-04 04:30

When creating a Process, target should be function name only without arguments or parantheses and then you add args=(your args). For example:

Process(target=func, args=(10,)).start()
查看更多
登录 后发表回答