Не работает многопоточность?

Question

[Totem]

Вопрос: использую threading для многопоточности, но тут возникла проблема которую как раз и должен решить многопоток, но она не исчезла. Вопрос в том, что код не продолжает выполнятся, хотя используется многопоточность.

Вот сам код:

def egz_checkden():
    svv = sqlite.GetInfo()
    svv.get_okdata()
    itt = sqlite.itt
    d = datetime.now()
    date = d.strftime('%d.%m.%Y')
    print(221)
    for x in itt:
        if x[4] < date:
            svv.useer_id = x[1]
            svv.udal_subs()
            with open(os.path.abspath(os.getcwd()) + '\HistorySubs\\' + x[1] + '.txt', 'a+') as file:
                if x[5] == '0':
                    file.write(f'User ID: {x[1]}\nUsername: {x[2]}\nData Start: {x[3]}\nData End: {x[4]}\nProdlen: No\nLimit: {x[7]}\n\n')
                    file.close()
                else:
                    file.write(f'User ID: {x[1]}\nUsername: {x[2]}\nData Start: {x[3]}\nData End: {x[4]}\nProdlen: Yes\nKolvo Prodlen: {x[6]}\nLimit: {x[7]}\n\n')
                    file.close()
    time.sleep(86400)
    egz_checkden()
Thread(target=egz_checkden(), args=())
chckden.start()
print('OK!') # Тут код уже не работает

Comments

[javedimka]

Твой код в принципе не работает. Показывай что написал полностью.

[Totem]

Там более 2-х тысяч строк, дам те строки который связаны с вопросом.

import telebot
import sqlite3
import random
import string
import time
import re
import requests
import os
from telebot import types
from datetime import datetime
import sqlite
import threading
from threading import Thread
import asyncio
bot = telebot.TeleBot(token='ТОКЕН')
db = sqlite3.connect('baza.db', check_same_thread=False)
tk = sqlite3.connect('token.db', check_same_thread=False)
cursor = db.cursor()
trsor = tk.cursor()
master_id = 1110551
startklava = types.ReplyKeyboardMarkup(resize_keyboard=True, one_time_keyboard=True, row_width=2)
button1 = types.KeyboardButton(text='Понятие')
button2 = types.KeyboardButton(text='О боте')
button3 = types.KeyboardButton(text='Личный кабинет')
startklava.add(button1, button2, button3)
def yes_check(status):
    global info
    info = status
def get_operator(phone):
    params = {'get_operator': '1', 'login': 'sster', 'psw': 'Ncm@F!vLGf', 'phone': phone, 'fmt': '3'}
    global o
    o = requests.get('https://smsc.ru/sys/info.php', params)
    o
def egz_checkden():
    svv = sqlite.GetInfo()
    svv.get_okdata()
    itt = sqlite.itt
    d = datetime.now()
    date = d.strftime('%d.%m.%Y')
    print(221)
    for x in itt:
        if x[4] < date:
            svv.useer_id = x[1]
            svv.udal_subs()
            with open(os.path.abspath(os.getcwd()) + '\HistorySubs\\' + x[1] + '.txt', 'a+') as file:
                if x[5] == '0':
                    file.write(f'User ID: {x[1]}\nUsername: {x[2]}\nData Start: {x[3]}\nData End: {x[4]}\nProdlen: No\nLimit Token: {x[7]}\n\n')
                    file.close()
                else:
                    file.write(f'User ID: {x[1]}\nUsername: {x[2]}\nData Start: {x[3]}\nData End: {x[4]}\nProdlen: Yes\nKolvo Prodlen: {x[6]}\nLimit Token: {x[7]}\n\n')
                    file.close()
    time.sleep(86400)
    egz_checkden()
Thread(target=egz_checkden(), args=())
chckden.start()
print('super')
def check_freeze(resu):
    global resuy
    resuy = resu
def genstop(message):
    if message.text == 'TINKOFF GAVNO':
        bot.send_message(message.chat.id, '*Бот остановлен принудительно!*', parse_mode='Markdown')
        dob_bot_zapis(message, 'Бот остановлен принудительно!')
        raise UserWarning
    else:
        bot.send_message(message.chat.id, '*Кодовое слово отвратительно!*', parse_mode='Markdown')
        dob_bot_zapis(message, 'Кодовое слово отвратительно!')

[mkone112]

Ох...мои глаза...

startklava

Больше global богу global!

[Roman K]

Документацию не читал, код написал, а потом «тостер памаги»?

[Totem]

Roman Kitaev, ещё один умник а-ля «документацию читай». Господи, форум создан не для того чтобы псевдо помощники писали «документацию читай» даже не приложив ссылку.

[Totem]

mkone112, не стоит делать выводов не зная полный код

[mkone112]

InternetMaster,

Господи, форум создан не для того чтобы псевдо помощники писали «документацию читай» даже не приложив ссылку.

Все верно, он создан чтобы угарать, чтобы ты там себе не придумал.

не стоит делать выводов не зная полный код

Т.е. этот кусок воняет, а все остальное нет? Ага.

[Totem]

mkone112, тебе следует удалить свой аккаунт. Сделай это прямо сейчас.

[mkone112]

InternetMaster, ты просишь меня удалить аккаунт, но ты просишь без уважения...

Answer 1

[Vindicar]

Thread(target=egz_checkden(), args=())

Когда уже погромисты научатся различать результат вызова функции (со скобками) и ссылку на функцию (без скобок).
У тебя сейчас Питон пытается выполнить egz_checkden(), чтобы получить её возвращаемое значение и использовать его в качестве target.

И да, у тебя в egz_checkden() бесконечная рекурсия, пусть и медленная. Вылетит с переполнением стека, хотя и не сразу. Не делай так, используй нормальный цикл.

Comments

[Vindicar]

InternetMaster, а ты перечитай ответ еще разок. Я тебе указал на ошибку и подсказал, как её исправить. Исправляй её уже сам.

[Totem]

Теоретически ответ полезен, но гораздо проще отправить одну строчку исправленного кода без скобок. И ответ получился бы "без лишней воды"

[mkone112]

InternetMaster, а еще проще было перечитать код. И не получился бы этот водяной вопрос.

[Сергей Горностаев]

Когда научатся учебники читать, тогда и отличать начнут.

Answer 2

[mkone112]

Мне кажется что все должно работать...эм...как и должно. С чего ты решил что оно должно дойти до print?

Comments

[Totem]

Ну так как это многопоточность? А для чего она создана? Разве не для того чтобы не мешать одной части кода исполнятся другой? В других частях кода именно так и работает.

[mkone112]

InternetMaster, вообще мне совершенно не ясно что за

svv.get_okdata()
itt = sqlite.itt
svv.useer_id

и т.д. Вероятно там оно где-нибудь и зависает. Зачем спрашивать выкладывая только этот кусок? Выложил бы одну строку вообще, зачем напрягаться?

[mkone112]

InternetMaster,

Ну так как это многопоточность?

Разве не для того чтобы не мешать одной части кода исполнятся другой?

Хз что ты имеешь в виду, но потоки в cpython блокирующие если что.

[Totem]

Вот этот кусок кода

def get_okdata(self):
        cursor.execute('SELECT * FROM subscribe')
        global itt
        itt = cursor.fetchall()

А что в твоем понимании выкладывая только этот кусок? Я выложил проблемную часть кода.

[Totem]

mkone112, они хоть и блокируещие, но исполняются крайне быстро "делая вид" что они параллельны. Так вот прикол в том, что многопоточность как раз не должна мешать выполнению дальнейшей части кода

[mkone112]

InternetMaster,

"делая вид" что они параллельны

Я сделал вид что закашлялся.

Я выложил проблемную часть кода.

Я бы сказал что весь код проблемный.
В целом тебе уже подсказали что ты передал результат вызова.

[Totem]

mkone112, ты на столько большой мастер что не смог понять что ошибка с скобках

[mkone112]

InternetMaster, не знаю насколько я большой, и насколько я мастер, но дальше "svv.udal_subs()" не читал. Второй листинг закрыл на первом global. Не вижу смысла это чинить.

Answer 3

[javedimka]

Thread(target=egz_checkden(), args=())

в target надо передавать объект функции, а не результат её выполнения

Thread(target=egz_checkden, args=())