python一个进程向dataframe中写入数据，一个进程读取dataframe中的数据

可以使用`multiprocessing`模块中的`Queue`来实现进程间通信，其中一个进程将数据写入`Queue`，另一个进程从`Queue`中读取数据并转化为`DataFrame`。

以下是一个示例代码：

import pandas as pd
from multiprocessing import Process, Queue

def write_func(q):
    # 将数据写入队列
    # 这里假定要写入的数据是一个列表，每个元素代表一行数据
    data = [[1, 'A'], [2, 'B'], [3, 'C']]
    q.put(data)

def read_func(q):
    # 从队列中读取数据并转化为DataFrame
    data = q.get()
    df = pd.DataFrame(data, columns=['id', 'name'])
    print(df)

if __name__ == '__main__':
    q = Queue()
    p1 = Process(target=write_func, args=(q,))
    p2 = Process(target=read_func, args=(q,))
    p1.start()
    p2.start()
    p1.join()
    p2.join()

在该示例代码中，`write_func`进程将数据写入`Queue`，`read_func`进程从`Queue`中读取数据并转化为`DataFrame`。注意，在`Queue`中传递的数据应该是可序列化的，这里将数据封装在列表中。`p1.join()`和`p2.join()`用于等待两个进程执行完毕。