Форум программистов [Powered by Invision Power Board]

Версия для печати темы
Нажмите сюда для просмотра этой темы в оригинальном формате

Форум программистов > Python: Общие вопросы > вопрос по pipe

Автор: Jessy 17.5.2019, 20:01

Вот код использования pipe который взят как пример и он работает. Одиночная отправка строки в канал и получение этой строки:

Код


import os
import sys
import time

_r, _w = os.pipe() 

processid = os.fork()
if processid:
    # This is the parent process 
    # Closes file descriptor w
    os.close(_w)
    r = os.fdopen(_r)
    print("Parent reading")

    str = r.read()
    print("text =", str)
    sys.exit(0)
else:
    # This is the child process
    os.close(_r)
    
    w = os.fdopen(_w, 'w')

    print("Child writing")
    w.write("Text written by child...")
    w.close()
    
    print("Child closing")
    sys.exit(0)

Если хочу слать сообщения по каналу в цикле, то ни одно не доходит. Вот так:

Код


import os
import sys
import time

_r, _w = os.pipe() 

processid = os.fork()
if processid:
    # This is the parent process 
    # Closes file descriptor w
    os.close(_w)
    r = os.fdopen(_r)
    print("Parent reading")
    while True:
        str = r.read()
        print("text =", str)
 
    sys.exit(0)
else:
    # This is the child process
    os.close(_r)
    
    w = os.fdopen(_w, 'w')
    while True:
        time.sleep(2)
        print("Child writing")
    
        w.write("Text written by child...")
        
    w.close()
    
    print("Child closing")
    sys.exit(0)

Буду признателен за подсказку в чем я туплю.

Автор: Jessy 17.5.2019, 23:06

Не поленился на Си проверить, работает:

Код


#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>

int main(void)
{
        int     fd[2], nbytes;
        pid_t   childpid;
        char    string[] = "Hello, world!\n";
        char    readbuffer[80];

        pipe(fd);
        
        if((childpid = fork()) == -1)
        {
                perror("fork");
                exit(1);
        }

        if(childpid == 0)
        {
                /* Child process closes up input side of pipe */
                close(fd[0]);

                /* Send "string" through the output side of pipe */
                for (;;) {
                    write(fd[1], string, (strlen(string)+1));
                    sleep(1);
                }
                
                exit(0);
        }
        else
        {
                /* Parent process closes up output side of pipe */
                close(fd[1]);

                /* Read in a string from the pipe */
                for (;;) {
                    nbytes = read(fd[0], readbuffer, sizeof(readbuffer));
                    printf("Received string: %s", readbuffer);
                }
        }
        
        return(0);
}

Чем для python такая конструкция особенная....

Автор: Jessy 17.5.2019, 23:38

Вот так работает.

Код


import os
import sys
import time
_r, _w = os.pipe() 
processid = os.fork()
if processid:
    # This is the parent process 
    # Closes file descriptor w
    print("Parent reading")
    while True:
        str = os.read(_r, 50)
        print("text =", str)
 
    os.close(_r)
    sys.exit(0)
else:
    # This is the child process

    while True:
        time.sleep(2)
        print("Child writing")
    
        os.write(_w, b"Text written by child...")
        
    os.close(_w)
    
    print("Child closing")
    sys.exit(0)

Спасибо мишка.