3

I have been using this link to learn about multiprocessing, but I'm stuck on the second example:

import multiprocessing
import time

class Consumer(multiprocessing.Process):

    def __init__(self, task_queue, result_queue):
        multiprocessing.Process.__init__(self)
        self.task_queue = task_queue
        self.result_queue = result_queue

    def run(self):
        proc_name = self.name
        while True:
            next_task = self.task_queue.get()
            if next_task is None:
                # Poison pill means we should exit
                print '%s: Exiting' % proc_name
                break
            print '%s: %s' % (proc_name, next_task)
            answer = next_task()
            self.result_queue.put(answer)
        return


class Task(object):
    def __init__(self, a, b):
        self.a = a
        self.b = b
    def __call__(self):
        time.sleep(0.1) # pretend to take some time to do our work
        return '%s * %s = %s' % (self.a, self.b, self.a * self.b)
    def __str__(self):
        return '%s * %s' % (self.a, self.b)


if __name__ == '__main__':
    # Establish communication queues
    tasks = multiprocessing.Queue()
    results = multiprocessing.Queue()

    # Start consumers
    num_consumers = multiprocessing.cpu_count() * 2
    print 'Creating %d consumers' % num_consumers
    consumers = [ Consumer(tasks, results)
                  for i in xrange(num_consumers) ]
    for w in consumers:
        w.start()

    # Enqueue jobs
    num_jobs = 10
    for i in xrange(num_jobs):
        tasks.put(Task(i, i))

    # Add a poison pill for each consumer
    for i in xrange(num_consumers):
        tasks.put(None)

    # Start printing results
    while num_jobs:
        result = results.get()
        print 'Result:', result
        num_jobs -= 1

First, could someone please explain exactly what multiprocessing.Process.__init__(self) does? Also I'm not entirely sure how the queue works, and I'm confused how the run method in the Consumer class is executed even though it is never called (explicitly at least...)

If someone could help me walk through the example to get the given output, it would be greatly appreciated.

4

3 に答える 3

1

クラスのオブジェクトが作成されると、その__init__()メソッドが自動的に呼び出されて初期化されます。2番目の例では、クラスConsumerはから継承するものとして定義されていmultiprocess.Processます。初期化で最初に行うことConsumerは、ベースを初期化してProcess、実行の準備ができていることを確認することです。多くのオブジェクト指向言語とは異なり、基本クラス__init__()関数はPythonで自動的に呼び出されません。

このrun()メソッドは、メインプロセスのオブジェクトでstart()呼び出されると、新しいプロセスで自動的に呼び出されます。Consumerそれはマルチプロセッシングドキュメントにあります。

これQueueは、複数のプロセスが通信する方法です。一般に、別々のプロセスは互いのデータを見ることができませんが、Queueメッセージをやり取りすることができます。この例では、メインプロセスはいくつかのタスクをキューに入れ、他の各プロセスはそのキューからタスクをプルして実行し、結果を別のキューに送り返します。

于 2012-06-25T20:04:39.107 に答える
0

うーん、これはあなたが探している答えではないかもしれません... しかし、私はそれが最良の答えだと思います.

オブジェクトは、Process作成時に多くの難しいものを作成する必要があります。確かに何をすべきかはわかりませんが、別のオペレーティングシステムプロセス、通信用のパイプなどを作成する必要があることはかなり確信しています。デフォルトでは、これらすべてが初期化メソッドで実行されます (Python では、と呼ばれる__init__()）。したがって、サブクラスを作成する場合Processは、親__init__()メソッドを呼び出して、プロセスが必要とするすべてのものを初期化する必要があります。あなたのConsumerクラスはすべての機能を実行する必要があるため、クラスにはすべての要素Processが含まれている必要がProcessあり、__init__()呼び出しによってそれが保証されます。

それが正確に何をするかは、実際には無関係です。それが のような既存のメソッドの要点です__init__(): それらはあなたのために大変な作業を実行し、あなたはそれを呼び出すだけで済みます。したがって、Python のソース コードを深く掘り下げて、 が何を__init__()行うのかを確認することもできますが、Python をこれから始めようとしていると思われるあなたにとっては、__init__()知る必要のない多くの初期化作業を行うのが最善の答えです。

于 2012-06-25T20:11:38.937 に答える
0

__init__クラスのコンストラクタです。背景についてはこちらをご覧ください。

ドキュメントによると、これはサブクラスで呼び出す必要があります。

サブクラスがコンストラクターをオーバーライドする場合、プロセスに対して他の処理を行う前に、サブクラスが基本クラスのコンストラクター ( Process.init ()) を呼び出すことを確認する必要があります。

于 2012-06-25T20:00:56.460 に答える