This library is for building multithreaded and fast C++ applications
- gtest
- wheel
git clone https://github.com/ilyajob05/QuickDataFlow.git
cd QuickDataFlow
chmod +x build.sh
./build.sh
Your need build library before install
sudo pdkg -i build/QuickDataFlow-2.1.0-Linux.deb
pip install QuickDataFlow
or download file from PyPi whl or tar.gz
pip install QuickDataFlow-2.1.2.tar.gz
# or
# pip install QuickDataFlow-2.1.2-cp310-cp310-manylinux2014_x86_64.whl
#include <opencv2/opencv.hpp>
#include "shm_message.hpp"
using namespace fshm;
using namespace std;
using namespace cv;
int main(int argc, char* argv[])
{
// create a buffer for data transfer
MessageBuff msg_buff("img_sender_point_i_", "img_sender_point_o_",
10, 10, 640 * 480 * 3, 640 * 480 * 3);
Mat inputImage = imread("../data/test-image-1.png");
Mat sendImage(480, 640, CV_8UC3);
resize(inputImage, sendImage, Size(640, 480));
cvtColor(sendImage, sendImage, COLOR_BGR2RGB); // for PIL
namedWindow("camera image sender", WINDOW_NORMAL);
// send data
uchar* arr = sendImage.isContinuous() ? sendImage.data : sendImage.clone().data;
msg_buff.push_message_sync(static_cast<unsigned char*>(arr));
imshow("camera image sender", inputImage);
waitKey(10000);
return 0;
}from PIL import Image
from QuickDataFlow import shm_message as sm
mb_buff = sm.MessageBuff("img_sender_point_o_", "img_sender_point_i_",
10, 10, 640 * 480 * 3, 640 * 480 * 3)
buff = bytes([0] * (640 * 480 * 3))
mb_buff.get_msg(buff)
img = Image.frombytes("RGB", (640,480), buff)
img.show()