如何使用joblib并行写入文件？JoinableQueue问题

from joblib import Parallel, delayed
import os

def write_to_file(filename, content):
    with open(filename, 'w') as file:
        file.write(content)

from queue import JoinableQueue
queue = JoinableQueue()

content1 = "This is content 1"
content2 = "This is content 2"
queue.put((filename1, content1))
queue.put((filename2, content2))

def process_queue():
    while not queue.empty():
        filename, content = queue.get()
        write_to_file(filename, content)
        queue.task_done()

num_cores = os.cpu_count()  # 获取CPU核心数
Parallel(n_jobs=num_cores)(delayed(process_queue)() for _ in range(num_cores))