並列処理内でのデータフレーム格納に失敗するスレッドがある

Question

前提・実現したいこと

pythonを使ってWebAPIの結果（json形式）を１つの行列に追記するシステムを並列処理を使って作っています。

発生している問題

同時実行数を増やした場合に一部の結果が格納されない状況となっております。
正しく全ての処理スレッドで結果を格納するためにはどのように変更すればよいでしょうか。
並列処理を使わない場合や、同時実行数が少ない場合は正しく格納されるため、同時に書き込む際にエラーもしくはプログラム作成としてのご法度があると思われます。
スクリプト単体で動作させたいため、データベース等への格納は考慮していません。

ソースコード

import pandas as pd
from concurrent import futures

columns = ['column_A','column_B','column_C']
df = pd.DataFrame(columns = columns )
df_0 = pd.DataFrame([[1,2,3]],columns = columns)
df_1 = pd.DataFrame([[4,5,6]],columns = columns)
df_2 = pd.DataFrame([[7,8,9]],columns = columns)

def sample_func(index):
    global df
    n = index % 3
    if n == 0:        
        df = df.append(df_0, ignore_index=True ,sort=False)
    elif n == 1:
        df = df.append(df_1, ignore_index=True ,sort=False)
    else:
        df = df.append(df_2, ignore_index=True ,sort=False)

def main():
    future_list = []
    with futures.ThreadPoolExecutor(max_workers=10) as executor:
        for index in range(30):
            future = executor.submit(fn=sample_func, index=index)
            future_list.append(future)
        _ = futures.as_completed(fs=future_list)
    print(df)

if __name__ == "__main__":
    main()

補足情報

Pythonのバージョン：3.7

Answer 1

きちんと排他処理を行いましょう

import threading
lock = threading.Lock()
def sample_func(index):
    global df
    n = index % 3
    if n == 0:
        with lock:
            df = df.append(df_0, ignore_index=True ,sort=False)
    elif n == 1:
        with lock:
            df = df.append(df_1, ignore_index=True ,sort=False)
    else:
        with lock:
            df = df.append(df_2, ignore_index=True ,sort=False)

Comments

[senisora]

ありがとうございます。
本番のプログラムでも正常にデータ格納することができました。
初歩だと思いますので、頂いたキーワードを元によく復習します……。