2

开发程序是使用 IPC 机制执行以下问题之一： 方式——“渠道”。通过在低阶行列式上展开方阵行列式来实现计算。“主”进程发送作业“驱动”进程，但后者执行行列式计算，然后计算主进程的结果。也就是说，需要用到管道功能。我有一个工作程序，但没有 IPC 机制。我不知道管道功能及其工作原理。

#include<stdio.h>
#include<math.h>
#include<stdlib.h>

int determinant(int n, double mat[n][n])
{
    int i,j,i_count,j_count, count=0;
    double array[n-1][n-1], det=0;
    if(n==1) return mat[0][0];
    if(n==2) return (mat[0][0]*mat[1][1] - mat[0][1]*mat[1][0]);

    for(count=0; count<n; count++)
    {
        i_count=0;
        for(i=1; i<n; i++)
        {
            j_count=0;
            for(j=0; j<n; j++)
            {
                if(j == count) continue;
                array[i_count][j_count] = mat[i][j];
                j_count++;
            }
            i_count++;
        }
        det += pow(-1, count) * mat[0][count] * determinant(n-1,array);
    }
    return det;
}

int main()
{
    int i, j, dim;
    printf("Enter n\n");
    scanf("%d", &dim);
    double matrix[dim][dim];
    printf("Enter matrix:\n");
    for(i = 0; i < dim; i++)
    {
        for(j = 0; j < dim; j++)
        {
            scanf("%lf \n", &matrix[i][j]);
        }
    }
    double x = determinant(dim, matrix);
    printf("Determinant = %g\n", x);
    return 0;
}
4

1 回答 1

1

几点注意事项：管道是单向的，一个进程写入，一个进程读取。所以当你启动管道时，如果一个进程正在从管道读取，应该关闭管道的写入端，反之亦然。否则你有发送数据的风险给自己，而不是把它发送给另一个进程。管道可以在fork（）之前启动，子进程继承管道（就像继承整个堆栈，除了pid）。
在此示例中，父进程要求输入一个矩阵，然后将其发送给子进程，子进程计算行列式并将其打印在屏幕上： 

#include<stdio.h>
#include<math.h>
#include<stdlib.h>
#include <unistd.h>

int determinant(int n, double mat[n][n])
{
    int i,j,i_count,j_count, count=0;
    double array[n-1][n-1], det=0;
    if(n==1) return mat[0][0];
    if(n==2) return (mat[0][0]*mat[1][1] - mat[0][1]*mat[1][0]);

    for(count=0; count<n; count++)
    {
        i_count=0;
        for(i=1; i<n; i++)
        {
            j_count=0;
            for(j=0; j<n; j++)
            {
                if(j == count) continue;
                array[i_count][j_count] = mat[i][j];
                j_count++;
            }
            i_count++;
        }
        det += pow(-1, count) * mat[0][count] * determinant(n-1,array);
    }
    return det;
}

int main()
{
    int i, j, dim;
    int fd[2];
    pipe(fd);
    pid_t pid=fork();
    if(pid)
    {
        // Father process
        close(fd[0]); // close the reading side of the pipe
        char buffer[100];
        printf("Enter n\n");
        fgets(buffer,100,stdin);
        dim=atoi(buffer);        // gets a float with atof
        double matrix[dim][dim];
        printf("Enter matrix:\n");
        for(i = 0; i < dim; i++)
        {
            for(j = 0; j < dim; j++)
            {
                fgets(buffer,100,stdin);
                matrix[i][j]=atof(buffer);
            }
        }
        write(fd[1],&dim,sizeof(double));  // write the size of the matrix
        write(fd[1], matrix, dim*dim*sizeof(double));  // write the matrix
        close(fd[1]);
    }
    else
    {
        // Child process
        close(fd[1]);  // close the writing side of the pipe
        int dim;
        read(fd[0], &dim, sizeof(double)); // read the dimension
        double matrix[dim][dim];  // read the matrix
        read(fd[0], matrix, dim*dim*sizeof(double));
        printf("%d",determinant(dim, matrix));
        close(fd[0]);
    }
    return 0;
}

重要提示：如果大小为负数，则可能存在分段错误或其他问题，因此还要测试 dim 是否为可接受的值。

在示例中我使用了 fgets，因为我不喜欢 scanf，这带来了清除缓冲区的问题。不幸的是，如何清除缓冲区也取决于系统，fflush(stdin) 在 windows 上效果很好，但在 linux 上你必须起诉另一种方法。只要您能够清理输入缓冲区，请随意使用 scanf。

于 2012-11-05T13:06:07.460 回答