c++ - 可以通过共享内存从不同进程更新 Eigen3 或其他矩阵库 2D 矩阵吗?

标签 c++ openmp shared-memory eigen3

eigen3 中这个程序的等价物是什么?我需要能够从单独的进程读取/写入共享内存矩阵,然后获取矩阵的特征值。似乎 Eigen3 可以使用 OpenMP,但我还没有找到一个明确的例子。

服务器:

#include <string>
#include <iostream>

#include <stdio.h>
#include <time.h>
#include <unistd.h>

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>

#include <sys/mman.h>


int main()
{
    int rows = 10; // The number of rows of the 2D array
    int columns = 30; // The number of columns of the 2D array
    int row, column;
    int *matrix;

    key_t ipc_key = 5678;   /* key to be passed to shmget()     */
    int shmflg = 0666;      /* shmflg to be passed to shmget()  */
    int id_shmem;           /* return value from shmget()       */
    int theSize;            /* size to be passed to shmget()    */

    theSize = sizeof(int) * rows * columns;

    // Create the shared memory segment
    id_shmem = shmget(ipc_key, theSize, IPC_CREAT | shmflg);

    // Attach the shared memory to our matrix
    matrix = (int *)shmat(id_shmem, 0, 0);

    int retVal = mlock(matrix, theSize);
    if(retVal)
        std::cout << "Error Locking" << std::endl;

    // Loop through all elements in the array
    for (row = 0; row < rows; row++)
    {
        for (column = 0; column < columns; column++)
        {
            matrix[row * columns + column] = column; // Equivalent to matrix[column][row]
        }
    }

    while (matrix[0] != -1)
        usleep(1);

    // Loop through all elements in the array
    for (row = 0; row < rows; row++)
    {
        std::cout << std::endl << row << "\t";

        for (column = 0; column < columns; column++)
        {
            std::cout << " " << matrix[row * columns + column]; // Equivalent to matrix[column][row]
        }

    }

    std::cout << std::endl;
}

客户
#include <string>
#include <iostream>

#include <stdio.h>
#include <time.h>
#include <unistd.h>

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>

#include <sys/mman.h>

// This is SXI see http://www.boost.org/doc/libs/1_50_0/doc/html/interprocess/sharedmemorybetweenprocesses.html
int main()
{
    int rows = 10; // The number of rows of the 2D array
    int columns = 30; // The number of columns of the 2D array
    int row, column;
    int *matrix;

    key_t ipc_key = 5678;   /* key to be passed to shmget()     */
    int shmflg = 0666;      /* shmflg to be passed to shmget()  */
    int id_shmem;           /* return value from shmget()       */
    int theSize;            /* size to be passed to shmget()    */

    theSize = sizeof(int) * rows * columns;

    // Create the shared memory segment
    id_shmem = shmget(ipc_key, theSize, shmflg);

    // Attach the shared memory to our matrix
    matrix = (int *)shmat(id_shmem, 0, 0);

    // Loop through all elements in the array
    for (row = 0; row < rows; row++)
    {
        std::cout << std::endl << row << "\t";

        for (column = 0; column < columns; column++)
        {
            std::cout << " " << matrix[row * columns + column]; // Equivalent to matrix[column][row]
        }
    }

    matrix[0] = -1;

    std::cout << std::endl;
}

最佳答案

事实证明,在 Eigen3 中可以做到这一点。使用 map

http://eigen.tuxfamily.org/dox/classEigen_1_1Map.html

关于c++ - 可以通过共享内存从不同进程更新 Eigen3 或其他矩阵库 2D 矩阵吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27683336/

相关文章:

c++ - C++中的惰性对象创建,或如何进行零成本验证

c++ - undefined reference

c++ - 排类系统

matrix - Fortran中多线程矩阵的转置

c++ - 静态内存中的 STL 结构 'Losing' 跨线程数据

c++ - 模拟静态函数成员

c++ - MC 模拟中的 openmp 私有(private)/共享数据

Python:在多个进程之间共享一个大型对象字典

sqlite - 数据共享 - SQLite 与共享内存 IPC

c++ - 在C++中,调用我的函数以根据程序的需要返回不同的类型时,是否有可能做一些时髦的事情?