poolMap.py

import joblib
import multiprocessing as mp

clf.fit(y_train, X_train)
weight = 'new_model.sav'
joblib.dump(clf, weight)


#define a function and pass your parameters 
def predict(A):
  y_test=A
  y_test=np.asarray(y_test)
  X_pred_prob = loaded_model.predict_proba(y_test)
  prediction= loaded_binarizer.inverse_transform(X_pred_new)
  print(prediction)
  #make sure you return the vaule, this would help you create the API
  return(A,prediction)

def mainPredict(Arr):
  # if Arr =[1,2,3,4,5,6] and each value is an input parameter to predict 
  #initialize pool 
  pool = mp.Pool(mp.cpu_count())
  
  #map array elements to the predict function
  result = pool.map(predict, Arr)
  
  #close the pool
  pool.close()
  
  return(result)