Threading inside multiprocessing

[kannanuv234]

#!/usr/bin/env python2.7
import multiprocessing
from threading import Thread

def do_stuff(i,s):
    print ("work from thread {} - list is {}".format(i,s))

def start_my_work(n,val):
    print ("Start work {} for {}".format(n,val))
    t_source = ['My','Name','Is','John','I','Work','In','IT']
    num_threads = 3
    for s in t_source:
        for i in range(num_threads):
            worker = Thread(target=do_stuff, args=(i,s))
            worker.setDaemon(True)
            worker.start()

jobs = []

p_source = ['hi','there','how','are','you','doing','Jay']

res = [p_source[x:x+2] for x in xrange(0, len(p_source), 2)]

for i,l in enumerate(res):
	for n in range(len(res[i])):
		val = res[i][n]
		p = multiprocessing.Process(target=start_my_work, args=(n,val))
		jobs.append(p)
		p.start()
	
	for p in jobs: #join on all processes ...
		p.join()

print "List processing complete."

Hi All,

I am trying to achieve threading inside each process of multiprocessing. I have 2 lists one for multiprocess (process) & another inside each process. My goal here is to go through p_source & for each process picks up all t_source (parallel) so i have used thread inside process. Also i need to restrict the process spawning to "2".

i have attached my code & am getting the expected output, but its without queue logic. Pls help review & is there any alternate way ? or Is this a right way ?

Regards
Kannan