Texte vergleichen

Finde den Unterschied zwischen zwei Textdateien

Echtzeit-Diff

Einheitlicher Diff

Zeilen einklappen

Änderungen hervorheben

Syntaxhervorhebung

Werkzeuge

Diffchecker Desktop The most secure way to run Diffchecker. Get the Diffchecker Desktop app: your diffs never leave your computer!Get Desktop

Untitled Diff

Created 4 years agoDiff never expires

Zeilen
Gesamt
Entfernt

Wörter
Gesamt
Entfernt

Um diese Funktion weiterhin zu nutzen, aktualisieren Sie auf Diffchecker Pro Preise anzeigen

88 Zeilen

Zeilen
Gesamt
Hinzugefügt

Wörter
Gesamt
Hinzugefügt

Um diese Funktion weiterhin zu nutzen, aktualisieren Sie auf Diffchecker Pro Preise anzeigen

66 Zeilen

import multiprocessing

import logging

import logging.handlers

import time

logger_pool = {}

class Loggers:

global logger_pool

def get_listener_logger(self, id):

formatter = logging.Formatter("%(message)s")

logger = logging.getLogger(id)

logger.setLevel(logging.INFO)

#handler = logging.handlers.RotatingFileHandler('log.log')

handler = logging.StreamHandler()

handler.setFormatter(formatter)

logger.addHandler(handler)

return logger

def get_worker_logger(self, id, queue):

"""

如果池中存在则取出

如果不存在则创建

"""

if logger_pool.get(id):

return logger_pool.get(id)

else:

"""

创建日志实例

"""

formatter = logging.Formatter("[%(asctime)s] %(name)s:%(levelname)s: %(message)s")

logger = logging.getLogger(id)

logger.setLevel(logging.INFO)

handler = logging.handlers.QueueHandler(queue)

handler.setFormatter(formatter)

logger.addHandler(handler)

logger_pool[id] = logger

return logger

logger_class = Loggers()

def listener_process(queue, flag_queue):

def listener_process(queue):

listener_logger = logger_class.get_listener_logger('listener')

formatter = logging.Formatter("%(message)s")

while True:

handler = logging.StreamHandler()

if queue.empty() and flag_queue.empty():

handler.setFormatter(formatter)

print('listener stop!')

listener = logging.handlers.QueueListener(queue, handler)

break

return listener

else:

try:

record = queue.get(timeout=2)

except:

continue

listener_logger.handle(record)

def worker_process(id, queue, flag_queue):

def worker_process(id, queue):

try:

logger = logger_class.get_worker_logger(id, queue)

for _ in range(10):

logger.info(time.time())

time.sleep(1)

finally:

print('worker stop!')

flag_queue.get()

if __name__ == "__main__":

queue = multiprocessing.Queue(-1)

flag_queue = multiprocessing.Queue(-1)

id_list = ['00', '01', '02', '03']

process_pool = []

for id in id_list:

flag_queue.put(id)

p = multiprocessing.Process(target=worker_process, args=(id, queue,))

p = multiprocessing.Process(target=worker_process, args=(id, queue, flag_queue,))

p.start()

process_pool.append(p)

listener = multiprocessing.Process(

listener = listener_process(queue)

target=listener_process, args=(queue, flag_queue,))

listener.start()

for p in process_pool:

p.join()

listener.join()

listener.stop()

Gespeicherte Diffs

Originaltext

Datei öffnen

import multiprocessing
import logging
import logging.handlers
import time

logger_pool = {}

class Loggers:
    global logger_pool

def get_listener_logger(self, id):
        formatter = logging.Formatter("%(message)s")
        logger = logging.getLogger(id)
        logger.setLevel(logging.INFO)

#handler = logging.handlers.RotatingFileHandler('log.log') 
        handler = logging.StreamHandler() 
        handler.setFormatter(formatter)
        logger.addHandler(handler)
        return logger

def get_worker_logger(self, id, queue):
        """
        如果池中存在则取出
        如果不存在则创建
        """
        if logger_pool.get(id):
            return logger_pool.get(id)
        else:
            """
            创建日志实例
            """
            formatter = logging.Formatter("[%(asctime)s] %(name)s:%(levelname)s: %(message)s")
            logger = logging.getLogger(id)
            logger.setLevel(logging.INFO)

handler = logging.handlers.QueueHandler(queue)
            handler.setFormatter(formatter)
            logger.addHandler(handler)
            logger_pool[id] = logger
            return logger

logger_class = Loggers()

def listener_process(queue, flag_queue):
    listener_logger = logger_class.get_listener_logger('listener')
    while True:
        if queue.empty() and flag_queue.empty():
            print('listener stop!')
            break
        else:
            try:
                record = queue.get(timeout=2)
            except:
                continue
            listener_logger.handle(record)

def worker_process(id, queue, flag_queue):
    try:
        logger = logger_class.get_worker_logger(id, queue)
        for _ in range(10):
            logger.info(time.time())
            time.sleep(1)
    finally:
        print('worker stop!')
        flag_queue.get()
    
if __name__ == "__main__":
    queue = multiprocessing.Queue(-1)
    flag_queue = multiprocessing.Queue(-1)
    
    id_list = ['00', '01', '02', '03']
    process_pool = []
    for id in id_list:
        flag_queue.put(id)

p = multiprocessing.Process(target=worker_process, args=(id, queue, flag_queue,))
        p.start()
        process_pool.append(p)

listener = multiprocessing.Process(
        target=listener_process, args=(queue, flag_queue,))
    listener.start()
    
    for p in process_pool:
        p.join()
    listener.join()

Geänderter Text

Datei öffnen

import multiprocessing
import logging
import logging.handlers
import time

logger_pool = {}

class Loggers:
    global logger_pool

handler = logging.handlers.QueueHandler(queue)
            handler.setFormatter(formatter)
            logger.addHandler(handler)
            logger_pool[id] = logger
            return logger

logger_class = Loggers()

def listener_process(queue):
    formatter = logging.Formatter("%(message)s")
    handler = logging.StreamHandler()
    handler.setFormatter(formatter)
    listener = logging.handlers.QueueListener(queue, handler)
    return listener

def worker_process(id, queue):
    try:
        logger = logger_class.get_worker_logger(id, queue)
        for _ in range(10):
            logger.info(time.time())
            time.sleep(1)
    finally:
        print('worker stop!')
    
if __name__ == "__main__":
    queue = multiprocessing.Queue(-1)
    
    id_list = ['00', '01', '02', '03']
    process_pool = []
    for id in id_list:
        p = multiprocessing.Process(target=worker_process, args=(id, queue,))
        p.start()
        process_pool.append(p)

listener = listener_process(queue)
    listener.start()
    
    for p in process_pool:
        p.join()
    listener.stop()