このページの翻訳:
- 日本語 (ja)
- English (en)
最近の更新
- 04 ↷ 50_dialy:2024:04:04 から 50_dialy:2024:04:05 へページを名称変更しました。
- 2024.04.02 Homebrewを入れる [各バージョン確認]
最近の更新
文書の過去の版を表示しています。
from concurrent.futures import ThreadPoolExecutor from logging import StreamHandler, Formatter, INFO, getLogger def init_logger(): handler = StreamHandler() handler.setLevel(INFO) handler.setFormatter(Formatter("[%(asctime)s] [%(threadName)s] %(message)s")) logger = getLogger() logger.addHandler(handler) logger.setLevel(INFO) def task(v): getLogger().info("%s start", v) time.sleep(1.0) def main(): global host db_host = '10.110.0.20' hosts = get_host(db_host) #print(hosts) init_logger() getLogger().info("main start") with ThreadPoolExecutor(max_workers=10, thread_name_prefix="thread") as executor: for i in range(5): executor.submit(task, i) getLogger().info("submit end") getLogger().info("main end") if __name__ == "__main__": main()