Databases
StackOverflow2013
Postsdbo
POPython function won't fully execute
 

Note that there are some explanatory texts on larger screens.

plurals
  1. POPython function won't fully execute
    primarykey
    data
    text
    <p>This is a dummy class to test a multiprocess generator. It takes a queue to pass a message, and a number indicating the number of times the thread has been called. For some reason I cant get the first print in the while loop to execute <code>print ("Thread type 1 number %d run count %d") % (thread_number, count)</code> wont run but<code>print ("Killing thread type 1 number %d") % thread_number</code> does run. </p> <pre><code>class test_imports:#Test classes remove def import_1(self, control_queue, thread_number): print ("Import_1 number %d started") % thread_number# Does run run = True count = 1 while run == True: alive = control_queue.get() print ("Thread type 1 number %d run count %d") % (thread_number, count) #wont run count = count + 1 if alive == 't1kill': print ("Killing thread type 1 number %d") % thread_number # does run run = False break </code></pre> <p>Here is the completed code</p> <pre><code>import multiprocessing import time class test_imports:#Test classes remove def import_1(self, control_queue, thread_number): print ("Import_1 number %d started") % thread_number run = True count = 1 while run == True: alive = control_queue.get() print ("Thread type 1 number %d run count %d") % (thread_number, count) count = count + 1 if alive == 't1kill': print ("Killing thread type 1 number %d") % thread_number run = False break def import_2(self, control_queue, thread_number): print ("Import_2 number %d started") % thread_number run = True count = 1 while run == True: alive = control_queue.get() print ("Thread type 2 number %d run count %d") % (thread_number, count) count = count + 1 if alive == 't2kill': print ("Killing thread type 2 number %d") % thread_number run = False break class worker_manager: def __init__(self): self.children = {} def generate(self, control_queue, threadName, runNum): i = test_imports() if threadName == 'one': print ("Starting import_1 number %d") % runNum p = multiprocessing.Process(target=i.import_1, args=(control_queue, runNum)) self.children[threadName] = p p.start() elif threadName == 'two': print ("Starting import_2 number %d") % runNum p = multiprocessing.Process(target=i.import_2, args=(control_queue, runNum)) self.children[threadName] = p p.start() elif threadName == 'three': p = multiprocessing.Process(target=i.import_1, args=(control_queue, runNum)) print ("Starting import_1 number %d") % runNum p2 = multiprocessing.Process(target=i.import_2, args=(control_queue, runNum)) print ("Starting import_2 number %d") % runNum self.children[threadName] = p self.children[threadName] = p2 p.start() p2.start() else: print ("Not a valid choice choose one two or three") def terminate(self, threadName): self.children[threadName].join if __name__ == '__main__': # Establish communication queues control = multiprocessing.Queue() manager = worker_manager() runNum = int(raw_input("Enter a number: ")) threadNum = int(raw_input("Enter number of threads: ")) threadName = raw_input("Enter number: ") thread_Count = 0 print ("Starting threads") for i in range(threadNum): manager.generate(control, threadName, i) thread_Count = thread_Count + 1 time.sleep(runNum)#let threads do their thing print ("Terminating threads") for i in range(thread_Count): control.put("t1kill") control.put("t2kill") manager.terminate(threadName) </code></pre>
    singulars
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PTQuestion
    1. USKyle Sponable
    1. USKyle Sponable
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. COPost the rest of your code.
      singulars
      1. POPython function won't fully execute
      1. USBlender
    2. COIt must be that control_queue.get() never returns, could that be it? Did you step through with the debugger?
      singulars
      1. POPython function won't fully execute
      1. USCodie CodeMonkey
    3. COI'd hazard a guess that control_queue is empty, so it blocks waiting for a producer to add something to it. Also, that `run = True; while run == True` bit hurts to look at. You don't even end up _using_ the flag you're twiddling. Just use `while True` and `break`.
      singulars
      1. POPython function won't fully execute
      1. USroippi
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload