Execute Python function in Main thread from call in Dummy thread

by

You want to use the Queue (now queue from python 3) class to set up a queue that your dummy threads populate with functions and that your main thread consumes.

import Queue

#somewhere accessible to both:
callback_queue = Queue.Queue()

def from_dummy_thread(func_to_call_from_main_thread):
    callback_queue.put(func_to_call_from_main_thread)

def from_main_thread_blocking():
    callback = callback_queue.get() #blocks until an item is available
    callback()

def from_main_thread_nonblocking():
    while True:
        try:
            callback = callback_queue.get(False) #doesn't block
        except Queue.Empty: #raised when queue is empty
            break
        callback()

Demo:

import threading
import time

def print_num(dummyid, n):
    print "From %s: %d" % (dummyid, n)
def dummy_run(dummyid):
    for i in xrange(5):
        from_dummy_thread(lambda: print_num(dummyid, i))
        time.sleep(0.5)
    
threading.Thread(target=dummy_run, args=("a",)).start()
threading.Thread(target=dummy_run, args=("b",)).start()

while True:
    from_main_thread_blocking()

Prints:

From a: 0
From b: 0
From a: 1
From b: 1
From b: 2
From a: 2
From b: 3
From a: 3
From b: 4
From a: 4

and then blocks forever

More Related Contents:

  1. How to use asyncio with threading in Python is Method threading.Timer
  2. Multiprocessing vs Threading Python [duplicate]
  3. Are lists thread-safe?
  4. Catch a thread’s exception in the caller thread?
  5. thread starts running before calling Thread.start
  6. Postponing functions in python
  7. How to use multiprocessing queue in Python?
  8. How to make built-in containers (sets, dicts, lists) thread safe?
  9. Using win32com with multithreading
  10. Threads and tkinter
  11. Multithreaded web server in python
  12. Program freezing during the execution of a function in Tkinter
  13. is python capable of running on multiple cores?
  14. How to run multiple jobs in one Sparkcontext from separate threads in PySpark?
  15. Kill a running subprocess call
  16. Python threading. How do I lock a thread?
  17. Python multithreaded print statements delayed until all threads complete execution
  18. Most Pythonic way to kill a thread after some period of time
  19. Python Threading inside a class
  20. Meaning of daemon property on Python Threads
  21. How to get the return value from a thread?
  22. Threaded Tkinter script crashes when creating the second Toplevel widget
  23. How to start threads at the same time in Python [duplicate]
  24. Is a variable swap guaranteed to be atomic in python?
  25. Restarting a thread in Python
  26. Python Tkinter Label redrawing every 10 seconds
  27. How to use QThread correctly in pyqt with moveToThread()?
  28. Is it thread-safe when using tf.Session in inference service?
  29. ‘sys.excepthook’ and threading
  30. Are locks unnecessary in multi-threaded Python code because of the GIL?

Leave a Comment