Эй, я просто хочу знать, возможно ли вернуть или выполнить действие в открытом процессе с модулем многопоточности.Пока я думаю, что это возможно только на верхнем уровне, где создается процесс.
Так что-то вроде этого:
from multiprocessing import Queue, Process
dataqueue = Queue()
#### put some data in dataqueue ####
p = Process(target=processWriting,args=(path,dataqueue,))
p.start()
p.join()
def processWriting(path,dataqueue):
try:
for data in dataqueue.get:
datalDF = pd.Dataframe(data)
except KeyboardInteruption:
dataDF.to_csv(path)