3

python でマルチスレッドを勉強中です

以下のようなクリティカルセッションでカウンタを増やすだけのプログラムを書いたのですが
LOCKを入れた途端デッドロックしてるのか何も表示されなくなります

import concurrent.futures
import time
import threading
LOCK = threading.Lock()

count = 0

def func1():
  with LOCK:   # この行がなければ動く
    count += 1
  print(count)


if __name__ == "__main__":
  executor = concurrent.futures.ThreadPoolExecutor(max_workers=2)
  while True:
    executor.submit(func1)
    time.sleep(1)
LOCK.acquire(blocking=True)
  count += 1
  LOCK.release()

と書いても同じです
count += 1
は絶対脱出するはずなのでデッドロックは起きようがないと思うんですが
C の pthread_mutex_lock のようなものではないんでしょうか

1

1 件の回答 1

3

グローバル変数宣言をしていないため、実行時にUnboundLocalErrorが起こっていることが原因です。

次のように修正してみてください。

def func1():
    global count
    with LOCK:
        count += 1
    print(count)

ランタイムエラーを見るにはFutureresult()メソッドやexeception()メソッドを使うと良いようです。

executor.submit(func1).add_done_callback(lambda f: print(f.exception()))
1
  • スレッド内でおきたエラーはデフォルトでは表示されないのですね。ありがとうございました
    – user35303
    Commented 2020年5月28日 10:35

この質問に回答するには、ログインする必要があります。