python - python中的并行执行失败?
问题描述
我有如下代码:
import pandas as pd
import multiprocessing as mp
a = {'a' : [1,2,3,1,2,3], 'b' : [5,6,7,4,6,5], 'c' : ['dog', 'cat', 'tree','slow','fast','hurry']}
df = pd.DataFrame(a)
def performDBSCAN(feature):
value=scorecalculate(feature)
print(value)
for ele in range(4):
value=value+1
print('here value is ', value)
return value
def processing(feature):
result1=performDBSCAN(feature)
return result1
def scorecalculate(feature):
scorecal=0
for val in ['a','b','c','d']:
print('alpha is:', val )
scorecal=scorecal+1
return scorecal
columns = df.columns
for ele in df.columns:
processing(ele)
上面的代码是以串行方式执行的。我想通过在 python 中使用多处理来提高速度并编写了以下代码。
import pandas as pd
import multiprocessing as mp
def performDBSCAN(feature):
value=scorecalculate(feature)
print(value)
for ele in range(4):
value=value+1
print('here value is ', value)
return value
def scorecalculate(feature):
scorecal=0
for val in ['a','b','c','d']:
print('alpha is:', val )
scorecal=scorecal+1
return scorecal
def processing(feature):
result1=performDBSCAN(feature)
return result1
a = {'a' : [1,2,3,1,2,3], 'b' : [5,6,7,4,6,5],
'c' : ['dog','cat','tree','slow','fast','hurry']}
df = pd.DataFrame(a)
columns = df.columns
pool = mp.Pool(4)
resultpool = pool.map(processing, columns)
我想查看输出但内核一直在运行而没有任何输出?可能是什么问题?
解决方案
推荐阅读
- c# - 获取 imagePath 的错误“参数无效”
- python - 过滤数据框并使用前一行数据
- java - SonarQube Scanner - 插件下载之间的长时间停顿
- google-places-api - Google Places API:文本搜索和附近搜索的不同输出(formatted_address 缺失)
- javascript - KarateUI 通配符定位器不匹配特殊字符(ä、ü、ö)
- c# - 我是编程新手,收到错误 CS7036
- c# - 使用嵌套托管将 MVC5 视图作为字符串获取
- android - 根据 Android 上选择的语言更改颜色
- javascript - LitElement 保持内部状态
- scala - 我如何计算相似度scala spark