jade.basic.threading package

jade.basic.threading.JobDistributor module

class jade.basic.threading.JobDistributor.JobDistributor(jobs, limit=10, verbose=True)[source]
execute()[source]
set_jobs_limit(limit)[source]
set_sleep_time(time_)[source]

jade.basic.threading.Threader module

class jade.basic.threading.Threader.Threader(print_interval=0)[source]

Bases: object

Class for starting 2 new threads. One that runs a system process and one that waits and prints info to std::out or whatever you currently have set as std::out. Use print interval to set the wait time between prints. Useful for GUI subprocessing.

run_functions(functions)[source]

Run a bunch of lambda functions together with multiprocessing :param functions: :return:

run_system_command(command)[source]

Run a system command using Popen. Prints out at end. Probably should remove this. :param command: :return:

class jade.basic.threading.Threader.Threads[source]

Class for managing threads, killing them on program exit.

append(thread)[source]
get_exitcode(pid)[source]
is_alive(pid)[source]
kill_all()[source]
n_alive()[source]
new_thread_allowed()[source]
set_allowed_threads(n)[source]
jade.basic.threading.Threader.print_loop(p, print_interval=0)[source]
jade.basic.threading.Threader.test_function(i, extra='')[source]