Function threadTest

POSIX/demo/TestInterProcessLock.cpp:61–101

}

bool threadTest() {
    sem_t *semParent = sem_open("/mmkv_main", O_CREAT, 0644, 0);

    //auto mmkv = MMKV::mmkvWithID(MMKV_ID, MMKV_MULTI_PROCESS);
    auto fd = open("/tmp/mmkv/TestInterProcessLock.file", O_RDWR | O_CREAT | O_CLOEXEC, S_IRWXU);
    flockPtr = new FileLock(fd);

    sem_post(semParent);
    cout << "Waiting for parent..." << endl;
    usleep(1000);
    sem_wait(semParent);
    sem_close(semParent);
    cout << "Parent locked" << endl;

    semEnded = sem_open(MMKV_ID, O_CREAT, 0644, 0);

    sem_t *semStarted = sem_open("/mmkv_sem_started", O_CREAT, 0644, 0);
    if (!semStarted) {
        printf("fail to create semphare: %d(%s)\n", errno, strerror(errno));
        exit(1);
    }
    for (int index = 0; index < 2; ++index) {
        pthread_t threadHandle;
        pthread_create(&threadHandle, nullptr, threadFunction, semStarted);
        sem_wait(semStarted);
        threadIndex++;
    }
    sem_close(semStarted);

    cout << "Waiting for any child exit..." << endl;
    usleep(1000);
    auto ret = sem_trywait(semEnded);
    sem_close(semEnded);
    cout << "Any child exit: " << (ret == 0) << endl;

    delete flockPtr;
    flockPtr = nullptr;
    //close(fd);

    return (ret != 0);
}

int main() {
    locale::global(locale(""));