import queue
import time
class ChatQueue:
def __init__(self):
self.queue = queue.Queue()
def add_message(self, message):
self.queue.put(message)
print(f"Сообщение добавлено в очередь: {message}")
def process_messages(self):
while not self.queue.empty():
message = self.queue.get()
print(f"Обработка сообщения: {message}")
time.sleep(1)
print(f"Сообщение обработано: {message}")
self.queue.task_done()
def main():
chat_queue = ChatQueue()
chat_queue.add_message("Привет!")
chat_queue.add_message("Как дела?")
chat_queue.add_message("У вас есть вопросы?")
print("Начало обработки сообщений...")
chat_queue.process_messages()
print("Все сообщения обработаны.")
if __name__ == "__main__":
main()
from queue import Queue
q = Queue()
while True:
msg = input()
q.put(msg)
while not q.empty():
msg = q.get()
print(msg)
from collections import deque
import threading
import time
class ChatQueue:
def __init__(self):
self.queue = deque()
self.lock = threading.Lock()
self.processing = False
def add_message(self, message):
with self.lock:
self.queue.append(message)
if not self.processing:
self.process_messages()
def process_messages(self):
self.processing = True
threading.Thread(target=self._process).start()
def _process(self):
while True:
with self.lock:
if not self.queue:
self.processing = False
break
message = self.queue.popleft()
print(f"Обработка сообщения: {message}")
time.sleep(1) # Имитация обработки сообщения
def main():
chat_queue = ChatQueue()
while True:
message = input("Введите сообщение (или 'q' для выхода): ")
if message.lower() == 'q':
break
chat_queue.add_message(message)
if __name__ == "__main__":
main()
from collections import deque
# Создаем пустую очередь
messages_queue = deque()
# Функция для добавления сообщения в очередь
def add_message(message):
messages_queue.append(message)
# Функция для обработки сообщений в очереди
def process_messages():
while messages_queue:
message = messages_queue.popleft()
print("Обрабатываем сообщение:", message)
# Добавляем сообщения в очередь
add_message("Привет, как дела?")
add_message("Что нового?")
add_message("Пока!")
# Обрабатываем сообщения
process_messages()
```
Вы можете запустить этот код в вашей среде разработки Python, чтобы увидеть, как он добавляет сообщения в очередь, обрабатывает их и удаляет из очереди. Надеюсь, это поможет вам решить задание! Если у вас есть еще вопросы или нужна дополнительная помощь, не стесняйтесь обращаться.