Pythonの並行処理

Question

Titleに並行処理と書きましたが、必ずしも私の誤解が並行処理に特有のところななのかは定かではありません。

Python実践入門という本の並行処理のところで以下のようなコードが出てきます。

import threading
class ThreadSafeCounter:
    # ロックを用意する
    lock = threading.Lock()
    def __init__(self):
        self.count = 0
    def increment(self):
        with self.lock:
            # 排他制御したい一連の処理をこのブロック内に書く
            self.count = self.count + 1


def count_up(counter):
    # 1,000,000回インクリメントする
    for _ in range(1000000):
        counter.increment()


counter = ThreadSafeCounter()
threads = 2
with ThreadPoolExecutor() as e:
    futures = [e.submit(count_up, counter)
               for _ in range(threads)]
    done, not_done = wait(futures)


# 期待通りの値になっている
print(counter.count)
>>> 2000000

このincrementメソッドのwith self.lockのところですが、クラス変数であるはずのlockがなぜインスタンス変数のように呼び出されているんでしょうか？また、なぜそれでうまくいってるのでしょうか？

個人的には

class ThreadSafeCounter:
    def __init__(self):
        self.count = 0
        self.lock = threading.Lock()
    def increment(self):
        with self.lock:
            # 排他制御したい一連の処理をこのブロック内に書く
            self.count = self.count + 1

のような気がするのですが、何か誤解ありましたら教えていただけますと幸いです。

Answer 1

単純に、クラス変数はselfでも参照できるからです。

https://docs.python.org/ja/3/tutorial/classes.html#class-and-instance-variables

ただ、明らかに読みにくいコードになるので、selfで参照するのではなく、ThreadSafeCounterで参照すべきだと個人的には思います。
言語仕様的になぜそれを許容するかわかりません。

Answer 2

** 以下の回答は、勘違いをしていて間違っていました。 すみません **
とりあえず消さずに残しておきます。

このlockクラス変数ではなく、インスタンス変数です。

処理の中で呼ばれているincrement関数も、counterというインスタンスをつくって、そのインスタンスのものが100万回呼ばれます。

この実装であれば、もう一つcounter2などのインスタンスを作れば、別のカウンターとして使うことができます。

Comments

[nouken]

ご回答ありがとうございます。lockはクラス変数という理解です。下の方の回答にもあるようにインスタンスからでもクラス変数を参照できるようです。間違いありましたら指摘いただけますと幸いです。

[TakaiY]

勘違いの回答でした。
すみません。
とりさげます。