TelebramBOT как запустить две функции одновременно?

Question

[Даня]

Как запустить две функции одновременно?

@bot.message_handler(content_types=['text'])
def timer(message):	   ### Эту и следующую нужно вместе запустить 
	msg = bot.send_message(chat_id=message.chat.id, text='START')
	time.sleep(1)
	msg_id = msg.message_id
	time_s = 5
	for t in range(time_s, 0, -1):
		bot.edit_message_text(chat_id=message.chat.id,  message_id=msg_id, text=f'Wait...{t}  секунд')
		time.sleep(1)
	bot.edit_message_text(chat_id=message.chat.id, message_id=msg_id, text='END')

def voice(message):
	CHUNK = 1024
	FORMAT = pyaudio.paInt16
	CHANNELS = 2
	RATE = 44100
	RECORD_SECONDS = 5
	WAVE_OUTPUT_FILENAME = "output.wav"

	p = pyaudio.PyAudio()

	stream = p.open(format=FORMAT,
	                channels=CHANNELS,
	                rate=RATE,
	                input=True,
	                frames_per_buffer=CHUNK)

	print("* recording")


	frames = []
	for i in range(0, int(RATE / CHUNK * RECORD_SECONDS)):

		data = stream.read(CHUNK)
		frames.append(data)


	
	send_notification(message)
	print("* done recording")

	stream.stop_stream()
	stream.close()
	p.terminate()

	wf = wave.open(WAVE_OUTPUT_FILENAME, 'wb')
	wf.setnchannels(CHANNELS)
	wf.setsampwidth(p.get_sample_size(FORMAT))
	wf.setframerate(RATE)
	wf.writeframes(b''.join(frames))
	wf.close()
	bot.send_audio(message.chat.id, open('output.wav', 'rb'))
	time.sleep(1)
	os.remove('output.wav')

Я пробывал:

from multiprocessing import Process
def func1(message):
     time.sleep(5)
     bot.send_message(message.chat.id, '1 - Функция.')

def func2(message):
      time.sleep(5)
      bot.send_message(message.chat.id, '2 - Функция.')

if __name__=='__main__':
     p1 = Process(target = func1)
     p1.start()
     p2 = Process(target = func2)
     p2.start()

Но в if__name__ нужно указать аргументы message, когда указываю то ошибка 'message is not defiend'.

Comments

[soremix]

Все правильно, что нужно message указать, бот же не наугад будет сообщение писать рандомному пользователю

[Даня]

SoreMix, Да, но как здесь указать аргумент message?!

if __name__=='__main__':
     p1 = Process(target = func1)
     p1.start()
     p2 = Process(target = func2)
     p2.start()

[soremix]

Даня  , а откуда вы его брать собрались?

[Даня]

SoreMix, Аргумент?

from multiprocessing import Process
def func1(message):
     time.sleep(5)
     bot.send_message(message.chat.id, '1 - Функция.')

def func2(message):
      time.sleep(5)
      bot.send_message(message.chat.id, '2 - Функция.')

if __name__=='__main__':
     p1 = Process(target = func1)
     p1.start()
     p2 = Process(target = func2)
     p2.start()

У меня в функциях func1 и func2 аргументы message

Answer 1

[Александр]

Вот Вам пример запуска параллельного потока счётчика и таймера на основе кода выше:

# -*- coding: utf-8 -*-
import telebot
from time import sleep
from threading import Thread

bot = telebot.TeleBot(token_test)


@bot.message_handler(commands=['start'])
def thread_main(message):
    Thread(target=timer, args=(message,)).start()
    Thread(target=counter, args=(message,)).start()


def timer(message):
    msg = bot.send_message(chat_id=message.chat.id, text='Timer start')
    sleep(1)
    msg_id = msg.message_id
    time_s = 15
    for t in range(time_s, 0, -1):
        bot.edit_message_text(chat_id=message.chat.id,  message_id=msg_id, text=f'Timer - {t}')
        sleep(1)
    bot.edit_message_text(chat_id=message.chat.id, message_id=msg_id, text='Timer End')


def counter(message):
    msg = bot.send_message(chat_id=message.chat.id, text='Count start')
    sleep(1)
    msg_id = msg.message_id
    count = 15
    for c in range(count):
        bot.edit_message_text(chat_id=message.chat.id,  message_id=msg_id, text=f'Count - {c}')
        sleep(1)
    bot.edit_message_text(chat_id=message.chat.id, message_id=msg_id, text='Count End')


if __name__ == "__main__":
    try:
        bot.polling(none_stop=True)
    except Exception as e:
        print(e)

Ссылки на понимание дали выше.

Comments

[Даня]

Спасибо!!

Answer 2

[Darvel]

Есть 2 способа сделать многопоточность:
Создай потоки https://geekbrains.ru/posts/python_threading_part1 Тут описываются примеры, как разблокировать GIL
Или функция multiprocessing https://docs.python.org/3.5/library/multiprocessin...