1

現在下記のようなコードで関数を並列化しています。

lock = threading.Lock()
for info in serverList:
    t = threading.Thread(target=getServerAsync, args=(servers, lock, info))
    t.start()

mainThread = threading.currentThread()
for t in threading.enumerate():
    if t is not mainThread:
        t.join()

詳しくはわかりませんがWebアプリケーションの場合マルチスレッドで複数のリクエストを処理していると考えられます。そこで、このようなコードをWebアプリケーションの関数、例えばFlaskのルータなどで動かすと、Webアプリケーションのプログラムに悪影響等はありますか。

もし悪影響が存在するならば、悪影響を及ぼさないで並列化させるにはどのようにすればいいでしょうか。

まだ作成していませんがWebのフレームワークはFlask+gunicorn or Flask+waitressを使用する予定です。よろしくお願いします。

2 件の回答 2

1

スレッドを配列に入れて、それをfor文を使ってjoinすることで実現できました。

threads = []
for info in serverList:
    t = threading(...)
    t.start()
    threads.append(t)

for t in threads:
   t.join()
0

スレッドを使うことに問題はありませんが、gunicornのコンテナの中でさらにスレッドを生成するわけで、制御するのが難しいでしょう。非同期のタスクを走らせたいならCeleryなどを使うことをお勧めします。

リンクだけ貼るのはルール違反ですが、具体的な問題が示されているわけではないので、回答も一般論ということで。

参考: Celery

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

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。