Schedule with other processing

[RValentim]

How can I create a schedule and continue with the parallel processing of other functions

sched = BlockingScheduler(timezone='UTC')
def my_job1():
    # stuff

sched.add_job(my_job1, 'cron', id='Job', minute=1)
sched.start()

def waiting():
    # function that is executed only when recive command

[gontajones]

Have you tried using Threads?
Python3 Threading

[RValentim]

not yet, would you have an example of how you would run a function every 10 minutes?

[gontajones]

import time
import threading


def my_function(n):
    """This is My Funtion"""
    print(f'Counter: {n}')


def main():
    """Start a Thread every x_minutes"""

    try:
        x_minutes = 10
        counter = 1
        while True:
            t = threading.Thread(target=my_function, args=(counter,))
            t.start()
            counter += 1
            time.sleep(60 * x_minutes)

    except KeyboardInterrupt:
        print('Leaving')


if __name__ == "__main__":
    main()

[RValentim]

I believe I was not very clear when expressing my doubts

the program I'm doing is executed and is waiting for user interest, when the user sends a command the program executes this command.

I want to put a function that is sending for example a status for the users, I tried to do by scheduling or thread and I could not, it is only executing the thread or the thread ignoring the commands sent by the users


Note: I do not know if the correct term would be Multiply Processing

[gontajones]

You could start a thread a status_function() and keep it alive until the end of the main() execution.

[RValentim]

When I try to do it or it just waits for commands or is only sending hourly statuses, I'm not getting it to do both at same time

run.py

class MyClass(object):
    def __init__(self):
        builder = StackBuilder()

        self.stack = builder\
            .pushDefault(encryption)\
            .push(Layer)\
            .build()

        self.stack.setCredentials(credentials)
        self.stack.setProp(CONTACTS,  list(config.keys()))
        self.stack.setProp(IDENTITY_AUTOTRUST, True)

    def start(self):
        print("[Start]\n")

        self.stack.Event(LayerEvent(Network.EVENT_STATE_CONNECT))

        try:
            self.stack.loop(timeout=0.5, discrete=0.5)
        except AuthError as e:
            print("ERROR: %s" % e)
        except KeyboardInterrupt:
            print("\nLeaving")
            sys.exit(0)

def run_infinite():
    while True:
        try:
            c = MyClass()
            c.start()
        except:
            pass
        else:
            break

if __name__ == "__main__":
    c = MyClass()
    c.start()

run.py call my_funcionts.py

my_funcionts.py

def handle(command):
    user = [ "rvalentim",
             "tgusmao",
                ]
    if command.users in user:
        if command.text == "info":
            info(command)
        elif command.text == "test":
            test(message)
        else :
            other(message)

'''
My funcionts module code
==========================================================
'''
def info(command):
    print("Info")

def test(command):
    print("Testing")

def other(command):
    print("Other info")
'''
==========================================================
'''

my_funcionts.py is in stand by waiting for user to send a command, but when I try to implement multiprocessing, where it continues waiting for commands to be received and at same time leave another routine running where it sends hourly status for example

[RValentim]

would anyone have any ideas to help me?