Организовать конвейерное взаимодействие между тремя процессами

@Am@Zonk@ · Регистрация: 29.03.2012

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

Организовать конвейерное взаимодействие между тремя процессами:
— первый процесс читает из текстового файла коэффициенты квадратного уравнения и помещает их в виде списка в первую блокирующую очередь;
— второй процесс берет очередной элемент из первой блокирующей очереди, решает соответствующее уравнение и помещает результат решения (список) во вторую блокирующую очередь;
— третий процесс берёт результаты из второй блокирующей очереди и выводит их в текстовый файл.
При достижении конца файла первый процесс помещает в очередь пустой список (маркер конца) и завершается. При получении пустого списка второй процесс помещает такой же список во вторую очередь и также завершается. Третий процесс при получении пустого списка закрывает файл и завершает работу. Основная программа дожидается присоединения всех трёх процессов, выводит соответствующее сообщение и завершается.

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
import multiprocessing
 
def f1(q):
    file = open("input.txt", "r")
    s = file.readlines()
    for i in s:
        i = i.split()
        q.put([i[0], i[1], i[2]])
    q.put([])
 
def f2(q_in, q_out):
    stopped = False
    while not stopped:
        item = q_in.get()
        if item == []:
            q_out.put([])
            stopped = True
        else:
            d = int(item[1]) ** 2 - 4 * int(item[0]) * int(item[2])
            if d < 0:
                q_out.put(["Действительных корней нет"])
            elif d == 0:
                q_out.put([(-int(item[1])) / (2 * int(item[0]))])
            else:
                q_out.put([(-int(item[1]) + d) / (2 * int(item[0])), (-int(item[1]) - d) / (2 * int(item[0]))])
 
def f3(q):
    file = open("output.txt", "w")
    print(q.get(), file = file)
    file.close()
 
    file = open("output.txt", "a")
    stopped = False
    while not stopped:
        item = q.get()
        if item == []:
            stopped = True
        else:
            print(item, file = file)
    file.close()
            
 
 
if __name__ == "__main__":
    q1 = multiprocessing.Queue()
    q2 = multiprocessing.Queue()
    p3 = multiprocessing.Process(target = f3, args = (q2,))
    p3.start()
    p2 = multiprocessing.Process(target = f2, args = (q1, q2))
    p2.start()
    p1 = multiprocessing.Process(target = f1, args = (q1,))
    p1.start()
    
    p1.join()
    p2.join()
    p3.join()

Не компилируется

accept · 13.07.2012, 03:23

помещай сразу числа, зачем эти int() повсюду
и нужно использовать float

Добавлено через 6 минут
у меня запускается и всё выводит
результаты неправильно выдаёт, потому что от дискриминанта надо корень брать

Добавлено через 15 минут

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
#!/usr/bin/env python3
 
import multiprocessing
 
def f1(q):
    with open("input.txt", encoding='utf-8') as fin:
        for line in fin:
            q.put(list(map(float, line.split())))
        q.put([])
 
def f2(q_in, q_out):
    stopped = False
    while not stopped:
        item = q_in.get()
        if item == []:
            q_out.put([])
            stopped = True
        else:
            a, b, c = item
            d = b ** 2 - 4 * a * c
            if d < 0:
                q_out.put(["Действительных корней нет"])
            elif d == 0:
                q_out.put([-b / (2 * a)])
            else:
                q_out.put([(-b + d ** 0.5) / (2 * a),
                           (-b - d ** 0.5) / (2 * a)])
 
def f3(q):
    with open("output.txt", "w",
              encoding='utf-8') as fout:
        stopped = False
        while not stopped:
            item = q.get()
            if item == []:
                stopped = True
            else:
                print(item, file=fout)
 
if __name__ == "__main__":
    q1 = multiprocessing.Queue()
    q2 = multiprocessing.Queue()
    p3 = multiprocessing.Process(target=f3, args=(q2,))
    p3.start()
    p2 = multiprocessing.Process(target=f2, args=(q1, q2))
    p2.start()
    p1 = multiprocessing.Process(target=f1, args=(q1,))
    p1.start()
    
    p1.join()
    p2.join()
    p3.join()

input.txt

output.txt

Code
1
2
3
[-1.0, -4.0]
[-0.25, -1.0]
[-0.6972243622680054, -4.302775637731995]

Добавлено через 4 минуты

для второго

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
#!/usr/bin/env python
# coding: utf-8
 
import multiprocessing
 
def f1(q):
    with open("input.txt") as fin:
        for line in fin:
            q.put(map(float, line.split()))
        q.put([])
 
def f2(q_in, q_out):
    stopped = False
    while not stopped:
        item = q_in.get()
        if item == []:
            q_out.put([])
            stopped = True
        else:
            a, b, c = item
            d = b ** 2 - 4 * a * c
            if d < 0:
                q_out.put([u"Действительных корней нет"])
            elif d == 0:
                q_out.put([-b / (2 * a)])
            else:
                q_out.put([(-b + d ** 0.5) / (2 * a),
                           (-b - d ** 0.5) / (2 * a)])
 
def f3(q):
    with open("output.txt", "w") as fout:
        stopped = False
        while not stopped:
            item = q.get()
            if item == []:
                stopped = True
            else:
                print >>fout, item
 
if __name__ == "__main__":
    q1 = multiprocessing.Queue()
    q2 = multiprocessing.Queue()
    p3 = multiprocessing.Process(target=f3, args=(q2,))
    p3.start()
    p2 = multiprocessing.Process(target=f2, args=(q1, q2))
    p2.start()
    p1 = multiprocessing.Process(target=f1, args=(q1,))
    p1.start()
    
    p1.join()
    p2.join()
    p3.join()

@Am@Zonk@ · 13.07.2012, 11:00 **[ТС]**

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

у меня запускается и всё выводит
результаты неправильно выдаёт, потому что от дискриминанта надо корень брать

Да, с дискриминантом это я что-то совсем...
Спасибо, буду пробовать.

Добавлено через 4 часа 49 минут

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

п

для второго

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
#!/usr/bin/env python
# coding: utf-8
 
import multiprocessing
 
def f1(q):
    with open("input.txt") as fin:
        for line in fin:
            q.put(map(float, line.split()))
        q.put([])
 
def f2(q_in, q_out):
    stopped = False
    while not stopped:
        item = q_in.get()
        if item == []:
            q_out.put([])
            stopped = True
        else:
            a, b, c = item
            d = b ** 2 - 4 * a * c
            if d < 0:
                q_out.put([u"Действительных корней нет"])
            elif d == 0:
                q_out.put([-b / (2 * a)])
            else:
                q_out.put([(-b + d ** 0.5) / (2 * a),
                           (-b - d ** 0.5) / (2 * a)])
 
def f3(q):
    with open("output.txt", "w") as fout:
        stopped = False
        while not stopped:
            item = q.get()
            if item == []:
                stopped = True
            else:
                print >>fout, item
 
if __name__ == "__main__":
    q1 = multiprocessing.Queue()
    q2 = multiprocessing.Queue()
    p3 = multiprocessing.Process(target=f3, args=(q2,))
    p3.start()
    p2 = multiprocessing.Process(target=f2, args=(q1, q2))
    p2.start()
    p1 = multiprocessing.Process(target=f1, args=(q1,))
    p1.start()
    
    p1.join()
    p2.join()
    p3.join()

А что за "u" перед "Действительных корней нет"?

accept · 13.07.2012, 11:08

строка из символов юникода, в третьем питоне все строки такие

Новые блоги и статьи Все статьи Все блоги /
Автозаполнение реквизита при выборе элемента справочника Maks 27.03.2026 Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. При выборе "Спецтехники" (Тип Справочник. Спецтехника), заполняется. . .	Сумматор с применением элементов трёх состояний. Hrethgir 26.03.2026 Тут. https:/ / fips. ru/ EGD/ ab3c85c8-836d-4866-871b-c2f0c5d77fbc Первый документ красиво выглядит, но без схемы. Это конечно не даёт никаких плюсов автору, но тем не менее. . . всё может быть. . .	Автозаполнение реквизитов при создании документа Maks 26.03.2026 Программный код из решения ниже размещается в модуле объекта документа, в процедуре "ПриСозданииНаСервере". Алгоритм проверки заполнения реализован для исключения перезаписи значения реквизита,. . .	Команды формы и диалоговое окно Maks 26.03.2026 1. Команда формы "ЗаполнитьЗапчасти". Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. В качестве источника данных. . .
Кому нужен AOT? DevAlt 26.03.2026 Решил сделать простой ланчер Написал заготовку: dotnet new console --aot -o UrlHandler var items = args. Split(":"); var tag = items; var id = items; var executable = args;. . .	Отправка уведомления на почту при изменении наименования справочника Maks 24.03.2026 Программная отправка письма электронной почты на примере изменения наименования типового справочника "Склады" в конфигурации БП3. Перед реализацией необходимо выполнить настройку системной учетной. . .	модель ЗдравоСохранения 5. Меньше увольнений- больше дохода! anaschu 24.03.2026 Теперь система здравосохранения уменьшает количество увольнений. 9TO2GP2bpX4 a42b81fb172ffc12ca589c7898261ccb/ https:/ / rutube. ru/ video/ a42b81fb172ffc12ca589c7898261ccb/ Слева синяя линия -. . .	Midnight Chicago Blues kumehtar 24.03.2026 Такой Midnight Chicago Blues, знаешь?. . Когда вечерние улицы становятся ночными, а ты не можешь уснуть. Ты идёшь в любимый старый бар, и бармен наливает тебе виски. Ты смотришь на пролетающие. . .

accept 4866 / 3288 / 468 Регистрация: 10.12.2008 Сообщений: 10,570
	13.07.2012, 11:08
	строка из символов юникода, в третьем питоне все строки такие 0