Передача сообщений между процессами и потоками

@lsn · Регистрация: 02.05.2015

Author24 — интернет-сервис помощи студентам

Здравствуйте, помогите, пожалуйста, с задачей по Операционным системам: Создать процесс с двумя дочерними процессами, процесс с двумя потоками и организовать передачу сообщений между всеми этими процессами.

В питоне я новичок, есть пару набросков, но я не уверен в их правильности.
Здесь я передаю сообщения через обычный pipe, но сложность в том, что сообщения помещаются в очередь и трудно контролировать, какое сообщение куда попадет

Python

import multiprocessing
import time
import threading
 
(pout,pin)=multiprocessing.Pipe()
#suprocess 1
def fun1(pin, pout):
    print(pout.recv())  
    pin.send('Child Process 1 send message to Child Process 2')
    print(pout.recv())   
    
#subprocess 2
def fun2(pin, pout):
    print(pout.recv())
    pin.send('Child Process 2 send message to Child Process 1')
    print(pout.recv())
 
#main process 2
def fun3(pin, pout):
    t1=threading.Thread(target=fun4, args=(pin, pout))
    t2=threading.Thread(target=fun4, args=(pin, pout))
    t1.start()
    t2.start()
 
#Threads    
def fun4(pin,pout):
    pin.send('Thread send message')
   
#main process 1 
if __name__ =='__main__':
    p1=multiprocessing.Process(target=fun1, args=(pin, pout ))
    p2=multiprocessing.Process(target=fun2, args=(pin, pout ))
    p1.start()
    p2.start()
    pin.send('Parent Process 1 send message to Child Process 1')
    pin.send('Parent Process 1 send message to Child Process 2')
 
    p3=multiprocessing.Process(target=fun3, args=(pin, pout))
    p3.start()
 
    print(pout.recv())
    
    p1.join()
    p2.join()
    p3.join()
    time.sleep(10)

Еще пробовал через сокеты, но приложение ругается на то, что нельзя передавать строки, числа, а только байты.
encode() , decode() не помогают.

Python

import multiprocessing
import time
import threading
import socket
 
#suprocess 1
def fun1():
    print('Child Process 1 started')
    sock=socket.socket()
    sock.connect(('localhost',64440))
    sdata=('Child Process 1 send message to Main Process')
    sdata.encode()
    sock.send(sdata)
    sock.close()
#subprocess 2
def fun2():
    print('Child Process 2 started')
 
#main process 2
def fun3():
    print('Process 2 started')
    t1=threading.Thread(target=fun4)
    t2=threading.Thread(target=fun4)
    t1.start()
    t2.start()
 
#Threads    
def fun4():
    print('Thread started')
   
#main process 1 
if __name__ =='__main__':
    print('Process 1 started')
    p1=multiprocessing.Process(target=fun1)
    p2=multiprocessing.Process(target=fun2)
    p1.start()
    p2.start()
 
    p3=multiprocessing.Process(target=fun3)
    p3.start()
 
    #server
    sock=socket.socket()
    sock.bind(('',64440))
    sock.listen(5)
    conn, addr=sock.accept()
    while True:
        data=conn.recv(1024)
        if not data:
            break
        data.decode()
        print(data)
    conn.close()
  
    p1.join()
    p2.join()
    p3.join()
    time.sleep(10)

@Eva Rosalene · 02.05.2015, 22:04

lsn, вызов encode не меняет переменную.
Делайте так:

Python

import multiprocessing
import time
import threading
import socket
 
#suprocess 1
def fun1():
    print('Child Process 1 started')
    sock=socket.socket()
    sock.connect(('localhost',64440))
    sdata='Child Process 1 send message to Main Process'
    sock.send(sdata.encode("utf-8"))
    sock.close()
#subprocess 2
def fun2():
    print('Child Process 2 started')
 
#main process 2
def fun3():
    print('Process 2 started')
    t1=threading.Thread(target=fun4)
    t2=threading.Thread(target=fun4)
    t1.start()
    t2.start()
 
#Threads    
def fun4():
    print('Thread started')
   
#main process 1 
if __name__ =='__main__':
    print('Process 1 started')
    p1=multiprocessing.Process(target=fun1)
    p2=multiprocessing.Process(target=fun2)
    p1.start()
    p2.start()
 
    p3=multiprocessing.Process(target=fun3)
    p3.start()
 
    #server
    sock=socket.socket()
    sock.bind(('',64440))
    sock.listen(5)
    conn, addr=sock.accept()
    while True:
        data=conn.recv(1024)
        if not data:
            break
        print(data.decode("utf-8"))
    conn.close()
  
    p1.join()
    p2.join()
    p3.join()
    time.sleep(10)

@0x10 · 03.05.2015, 09:09

Сообщение от lsn

организовать передачу сообщений между всеми этими процессами

Нужна конкретика: какого характера передача сообщений. Точка-точка, коллективные обмены.

Сообщение от lsn

сложность в том, что сообщения помещаются в очередь и трудно контролировать, какое сообщение куда попадет

Значит, на каждый процесс нужен отдельный канал. Реализация не важна: будь это пайп, сокет или любая очередь прикладного уровня.

@lsn · 03.05.2015, 13:19 **[ТС]**

Если действовать через сокеты, то на каждый процесс нужен и сервер и клиент?

Новые блоги и статьи Все статьи Все блоги /
Использование кэша Laravel - полный гайд bytestream 18.02.2025 Кэширование - один из наиболее эффективных способов повышения производительности веб-приложений. В современном мире, где скорость загрузки страниц напрямую влияет на удержание пользователей и. . .	Создаем REST API в Laravel с аутентификацией и Passport bytestream 18.02.2025 Разработка современных веб-приложений все чаще требует создания надежного и хорошо структурированного API. REST API стал стандартом де-факто для построения взаимодействия между клиентской и серверной. . .	Пайплайны в Laravel - полный гайд bytestream 18.02.2025 Разработка современных веб-приложений часто требует обработки сложных процессов, состоящих из множества последовательных шагов. Например, при создании системы комментариев может потребоваться. . .	Как правильно использовать @required в Symfony bytestream 18.02.2025 При разработке приложений на Symfony мы часто сталкиваемся с необходимостью внедрения зависимостей. Фреймворк предоставляет несколько способов управления этим процессом, и одним из таких инструментов. . .	Система безопасности в Laravel: возможности и примеры Wired 18.02.2025 Каждый день появляются новые виды атак и уязвимостей, которые могут поставить под угрозу конфиденциальные данные пользователей и функционирование всей системы. В этом контексте выбор надежного. . .
Давайте сравним Django и Laravel Wired 18.02.2025 Django и Laravel - два мощных инструмента, которые часто сравнивают между собой. Оба фреймворка предлагают разработчикам богатый набор возможностей для создания масштабируемых веб-приложений, но. . .	Laravel или React - что лучше? Wired 18.02.2025 В разработке веб выбор правильного инструмента часто определяет успех всего проекта. Особенно интересным представляется сравнение Laravel и React - двух популярных технологий, которые часто. . .	Laravel 11: новые возможности, гайд по обновлению Wired 18.02.2025 Laravel 11 - это новая масштабная версия одного из самых популярных PHP-фреймворков, выпущенная в марте 2024 года. Эта версия продолжает традицию внедрения передовых технологий и методологий. . .	Миграции в Laravel Wired 18.02.2025 Разработка веб-приложений на Laravel неразрывно связана с управлением структурой базы данных. При работе над проектом часто возникает необходимость вносить изменения в схему базы данных - добавлять. . .	Аутентификация в Laravel Wired 18.02.2025 В современном мире веб-разработки безопасность пользовательских данных становится критически важным аспектом любого приложения. Laravel, как один из самых популярных PHP-фреймворков, предоставляет. . .

@0x10 3258 / 2060 / 351 Регистрация: 24.11.2012 Сообщений: 4,909
	03.05.2015, 09:09	3
	Сообщение от lsn организовать передачу сообщений между всеми этими процессами Нужна конкретика: какого характера передача сообщений. Точка-точка, коллективные обмены. Сообщение от lsn сложность в том, что сообщения помещаются в очередь и трудно контролировать, какое сообщение куда попадет Значит, на каждый процесс нужен отдельный канал. Реализация не важна: будь это пайп, сокет или любая очередь прикладного уровня. 1

@lsn 0 / 0 / 0 Регистрация: 02.05.2015 Сообщений: 3
	03.05.2015, 13:19 [ТС]	4
	Если действовать через сокеты, то на каждый процесс нужен и сервер и клиент? 0

	02.05.2015, 21:53

Опции темы