mirror of
https://github.com/cryptosharks131/lndg.git
synced 2026-08-19 13:17:52 +02:00
23 lines
525 B
Python
23 lines
525 B
Python
import multiprocessing
|
|
import jobs, rebalancer, htlc_stream, p2p
|
|
|
|
def run_task(task):
|
|
task()
|
|
|
|
def main():
|
|
tasks = [jobs.main, rebalancer.main, htlc_stream.main, p2p.main]
|
|
print('Controller is starting...')
|
|
|
|
processes = []
|
|
for task in tasks:
|
|
process = multiprocessing.Process(target=run_task, args=(task,))
|
|
processes.append(process)
|
|
process.start()
|
|
|
|
for process in processes:
|
|
process.join()
|
|
|
|
print('Controller is stopping...')
|
|
|
|
if __name__ == '__main__':
|
|
main()
|