import concurrent
from concurrent.futures import ThreadPoolExecutor

import multiprocessing

from horo.models import commit
from horo.models.article import Article

messages = Article.query.offset(0).limit(3).all()


def task(message):
    print(message.id)
    print(message.title)
    print(message.content)


with ThreadPoolExecutor(max_workers=multiprocessing.cpu_count() * 5) as executor:
    for message in messages:
        message.subtitle = ''
    commit()
    result_future = {executor.submit(task, message): message for message in messages}
    for future in concurrent.futures.as_completed(result_future):
        message = result_future[future]
        future.result()
        print(message.id)