5

次の 2 つの関数をまったく同時に実行したいと考えています。

from multiprocessing import Process
import os
import datetime

def func_1(title):
    now = datetime.datetime.now()
    print "hello, world"
    print "Current second: %d" % now.second
    print "Current microsecond: %d" % now.microsecond

def func_2(name):
    func_1('function func_2')
    now = datetime.datetime.now()
    print "Bye, world"
    print "Current second: %d" % now.second
    print "Current microsecond: %d" % now.microsecond

if __name__ == '__main__':
    p = Process(target=func_2, args=('bob',))
    p.start()
    p.join()

そして、私はマイクロ秒単位で違いを得ています。両方を同時に実行する方法はありますか？どんな助けでも大歓迎です。

4

4 に答える 4

5

これは、（1）一般的に不可能（「正確な」部分）であり、（2）Pythonが得意なことではありません。マイクロ秒の実行精度が本当に必要な場合は、CまたはASMを使用しますが、COpythonの答えよりもさらに近い方法では、2つの異なるプロセスで合意された開始時刻を待機することになります。

from multiprocessing import Process
import os
import datetime
from time import time

def func_1(title):
    now = datetime.datetime.now()
    print "hello, world"
    print "Current second: %d" % now.second
    print "Current microsecond: %d" % now.microsecond

def func_2(name):
    now = datetime.datetime.now()
    print "Bye, world"
    print "Current second: %d" % now.second
    print "Current microsecond: %d" % now.microsecond

def start_f1(name):
    while time() < start_time: pass
    func_1(name)

def start_f2(name):
    while time() < start_time: pass
    func_2(name)        

if __name__ == '__main__':
    procs = []
    procs.append(Process(target=start_f2, args=('bob',)))
    procs.append(Process(target=start_f1, args=('sir',)))
    start_time = time() + 10
    map(lambda x: x.start(), procs)
    map(lambda x: x.join(), procs)
于 2012-11-20T14:32:05.470 に答える
5

以下が書かれたコンピューターでは、このコードは一貫して同じタイムスタンプを出力します。

#! /usr/bin/env python3
from multiprocessing import Barrier, Lock, Process
from time import time
from datetime import datetime

def main():
    synchronizer = Barrier(2)
    serializer = Lock()
    Process(target=test, args=(synchronizer, serializer)).start()
    Process(target=test, args=(synchronizer, serializer)).start()

def test(synchronizer, serializer):
    synchronizer.wait()
    now = time()
    with serializer:
        print(datetime.fromtimestamp(now))

if __name__ == '__main__':
    main()
于 2012-11-20T17:53:34.637 に答える
2

これがまったく同時に実行されるかどうかはわかりませんが、より近くなると思います。

from multiprocessing import Process
import os
import datetime


def func_1(title):
    now = datetime.datetime.now()
    print "hello, world"
    print "Current second: %d" % now.second
    print "Current microsecond: %d" % now.microsecond


def func_2(name):
    now = datetime.datetime.now()
    print "Bye, world"
    print "Current second: %d" % now.second
    print "Current microsecond: %d" % now.microsecond


if __name__ == '__main__':
    procs = []
    procs.append(Process(target=func_2, args=('bob',)))
    procs.append(Process(target=func_1, args=('sir',)))
    map(lambda x: x.start(), procs)
    map(lambda x: x.join(), procs)
于 2012-11-20T14:21:00.487 に答える
1

CPython本質的にシングル スレッドです (Google の「グローバル インタープリター ロック」)。理論的なチャンスを得るには、マルチコア プロセッサが必要になりますが、それでも非常に低いレベルで動作するオペレーティング システムのみがそれを実行でき、その場合でも特別なハードウェアが必要になります。 、 無理だよ。

于 2012-11-20T15:57:37.797 に答える