0

1 番目のプロセスが係数をファイルに書き込むのを 2 番目のプロセスで適切に待機させるにはどうすればよいですか?

私の仕事は、セマフォを使用して 2 つのプロセスを同期することです。1 番目のプロセスがデータを読み取り、ファイルに書き込み、次に 2 番目のプロセスがこのデータを読み取って解を見つけ、それをファイルに書き込み、次に 1 番目のプロセスがこの解をファイルから読み取り、解をコンソールに出力します。

/親ファイルは次のとおりです: /

#include "stdafx.h"                            

const char* FIRST_SEMAPHORE = "Semaphore1";
const char* SECOND_SEMAPHORE = "Semaphore2";

const char* FIRST_PROCESS = "Lab2_first.exe";
const char* SECOND_PROCESS = "Lab2_second.exe";

int _tmain(int argc, _TCHAR* argv[])
{
    STARTUPINFO sInfo;
    PROCESS_INFORMATION pInfo;

    CreateSemaphore(NULL, 0, 1, (LPCWSTR) FIRST_SEMAPHORE);      
    CreateSemaphore(NULL, 0, 1, (LPCWSTR) SECOND_SEMAPHORE);

    GetStartupInfo(&sInfo);        

    if(!CreateProcess(ConvertLPCSTRToLPWSTR(SECOND_PROCESS), NULL, NULL, 
            NULL, FALSE, 0, NULL, NULL, &sInfo, &pInfo))
    {  
        printf("Second process failed: %d\n", GetLastError());
    }

    if(!CreateProcess(ConvertLPCSTRToLPWSTR(FIRST_PROCESS), NULL, NULL, 
         NULL, FALSE, 0, NULL, NULL, &sInfo, &pInfo))
    {
        printf("First process failed: %d\n", GetLastError());      
    }


    return 0;
}

/ここにプロセス 1 (Lab2_first) があります: /

#include "stdafx.h"
#include "windows.h"

const char* FIRST_SEMAPHORE = "Semaphore1";
const char* SECOND_SEMAPHORE = "Semaphore2";

int _tmain(int argc, _TCHAR* argv[])
{
    HANDLE semaphore1, semaphore2;
    semaphore1 = OpenSemaphore(EVENT_ALL_ACCESS, TRUE, 
          ConvertLPCSTRToLPWSTR(FIRST_SEMAPHORE));
    semaphore2 = OpenSemaphore(EVENT_ALL_ACCESS, TRUE, 
            ConvertLPCSTRToLPWSTR(SECOND_SEMAPHORE));

    Equation equation;
    printf("Enter coefficients: ");
    scanf("%d %d %d", &equation.a, &equation.b, &equation.c);

    HANDLE file = CreateFile(ConvertLPCSTRToLPWSTR("equation"), 
          GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN_EXISTING, 
             FILE_ATTRIBUTE_NORMAL, 0);

    DWORD number = sizeof(equation);
    LPDWORD numberOfBytesWritten = &number;
    WriteFile(file, &equation, sizeof(equation), numberOfBytesWritten, 
                                          NULL);

    printf("1: write to file");

    ReleaseSemaphore(semaphore1, 1, NULL);
    WaitForSingleObject(semaphore2, INFINITE);

    ReadFile(file, &equation, sizeof(equation), numberOfBytesWritten, 
                                   NULL);

    if(equation.hasSolution)
    {
        printf("Solution");
    } else {
        printf("No solution");
    }

    char data[10];
    scanf("%s", data);
    return 0;
}

/これが 2 番目のプロセス (Lab2_second) です: /

#include "stdafx.h"
#include "windows.h"

const char* FIRST_SEMAPHORE = "Semaphore1";
const char* SECOND_SEMAPHORE = "Semaphore2";

int _tmain(int argc, _TCHAR* argv[])
{
    HANDLE semaphore1, semaphore2;
    semaphore1 = OpenSemaphore(EVENT_ALL_ACCESS, TRUE, `enter code 
                           here`ConvertLPCSTRToLPWSTR(FIRST_SEMAPHORE));
    semaphore2 = OpenSemaphore(EVENT_ALL_ACCESS, TRUE, 
                            ConvertLPCSTRToLPWSTR(SECOND_SEMAPHORE));

    WaitForSingleObject(semaphore1, INFINITE);

    printf("2: read from file");

    HANDLE file = CreateFile(ConvertLPCSTRToLPWSTR("equation"), 
                       GENERIC_WRITE, FILE_SHARE_READ, NULL, 
                     OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, 0);

    Equation equation;
    DWORD number = sizeof(equation);
    LPDWORD numberOfBytesWritten = &number;
    ReadFile(file, &equation, sizeof(equation), numberOfBytesWritten, 
                        NULL);

    // todo

    equation.hasSolution = FALSE;
    WriteFile(file, &equation, sizeof(equation), numberOfBytesWritten, 
                           NULL);

    ReleaseSemaphore(semaphore2, 1, NULL);

    return 0;
}

問題は、親が開始したときに、2 番目のプロセスが 1 番目のリリース semaphore1 まで待たず (つまり、2 番目のプロセスが WaitForSingleObject (semaphore1, INFINITE) に反応しない)、最初からファイルから読み取る理由です (これは起動時にクリア: 2 番目のプロセスはすぐに「2: ファイルから読み取り」を表示しますが、そこには何もありません。1 番目のプロセスが係数をファイルに書き込むのを 2 番目のプロセスで適切に待機させるにはどうすればよいですか?

4

0 に答える 0