每行的splitCsv join通道多次执行下一次流

import csv
from collections import deque

# 读取CSV文件
with open('data.csv', 'r') as file:
    reader = csv.reader(file)
    buffer = deque()

    for row in reader:
        # 分割每行数据
        fields = row.split(',')
        buffer.append(fields)

        # 当缓冲区达到一定大小时，执行join操作
        if len(buffer) >= 10:
            process_buffer(buffer)
            buffer.clear()

# 处理剩余的缓冲区数据
if buffer:
    process_buffer(buffer)

def process_buffer(buffer):
    # 执行join操作
    for fields in buffer:
        # 处理合并后的数据
        print(fields)

import csv
import threading

# 读取CSV文件
with open('data.csv', 'r') as file:
    reader = csv.reader(file)
    buffer = []

    def split_csv():
        for row in reader:
            fields = row.split(',')
            buffer.append(fields)

    def join_csv():
        while True:
            if buffer:
                fields = buffer.pop(0)
                # 处理合并后的数据
                print(fields)

    # 启动split和join线程
    split_thread = threading.Thread(target=split_csv)
    join_thread = threading.Thread(target=join_csv)

    split_thread.start()
    join_thread.start()

    split_thread.join()
    join_thread.join()