Multithreading in a loop

[valtih]

I tried the following to create two worker processes

1 2 3 4 5 6

import threading for i in range(0, 2):     def spawnAWorker():         printf("%s", i)         #os.system('start cmd /K ' + workerCmd)     threading.Thread(target=lambda: spawnAWorker()).start()

The problem is that printf prints me 1 two times instead of 0 and 1 Why? What can I do to start the first worker with id 0 and another with id 1?

[valtih]

I have discovered that the problem goes away if I do not start the threads immediately:

1 2 3 4 5

def spawnAWorker(i):     printf("%s", i)     #os.system('start cmd /K ' + workerCmd) threads = map(lambda i: threading.Thread(target=lambda: spawnAWorker(i)),range(0,2)) for t in threads: t.start()

But, I see a problem here as well. If range is larger, say (0,100), I do not see all numbers printed. Some threads do not start.

---

I have to inject a delay

1 2 3

for t in threads:     t.start()     time.sleep (1) ## this sucks but some threads do not start if I launch them all at the same time

if I want all threads to start. I want more deterministic solution.

[nilamo]

Do you ever .join() on the threads, to wait for them to finish?  Maybe the main thread finishes before all the sub-threads get started.

[valtih]

You are right!