C库从BG线程调用kdb函数-Java 学习之路

我有一个外部C库，用于通过后台线程上的回调函数异步使用数据;我想接收数据并在q过程中处理它 . 在code.kx.com的Interfacing with C文档之后，我创建了一个小型的胶水代码库，将入站源数据转换为k结构并将其分派给我的q进程vi sd1 / sd0调用，以便在q的线程上下文中调用q函数 . 程序成功调用初始回调然后挂起 .

我已经把程序剥离到了我认为只是简单地演示一个C BG线程回调到q函数的最低限度，但是我不确定我是否已经剥离了太多 . 例如，sd1接受FD和C回调 . 我的最小FD是通过eventfd（）创建的，后者用于后续的sd1 / sd0调用 . 我尝试在FD上调用读写，而不是通过FD执行任何IO，无论程序挂起 .

这是我的骨架C库：

/* testlib.c */
#define KXVER 3
#include "k.h"
#include <pthread.h>
#include <sys/eventfd.h>
I d;
pthread_t tid;
K qdisp(I d)
{
        K ignored = k(0, (S)"onCB", kj(54321), (K)0);
        sd0(d);
        return (K)0;
}
void* loop(void* vargs)
{
        while(1) {
                sleep(1);
                sd1(d, qdisp);
        }
        return NULL;
}
K init(K ignore)
{
        d = eventfd(1, 0);
        int err = pthread_create(&tid, NULL, &loop, NULL);
        return (K)0;
}

这是调用它的q脚本：

/ testlib.q
init:`testlib 2:(`init;1)
onCB:{ 0N!x }
init[`blah]

任何提示或评论赞赏 .

2 回答

0

你确定对方提供了足够的数据吗？正如我从您引用的文档中看到的那样，通过使用 blocking 管道进行通信 . 这意味着如果没有足够的数据，或者生产环境者没有刷新缓冲区，则应用程序 should 阻塞，这是它的预期行为 .

您可以尝试使用 sd0()/sd1() 跳过 d 参数来验证观察到的行为是由阻塞管道引起的，而不是由其他东西引起的 .

回复于 2024-04-27T06:00:37+08:00

对于那些感兴趣的人来说，看起来sd1调度每次有可用于在文件描述符上读取的数据时调用的函数，并且sd0从调用中删除调度的函数 .

所以想法是编写一个试图从FD读取的函数;如果成功，通过k（）调用q函数并返回结果，如果0只返回0，如果错误调用sd0 .

#define KXVER 3
#include "k.h"
#include <pthread.h>
#include <sys/eventfd.h>
#include <stdio.h>
I d;
pthread_t tid;
K qdisp(I d)
{
    J v;
    if (-1 != read(d, &v, sizeof(J)) ) {
        return k(0, "onCB", ki(v), (K)0);
    }
    sd0(d);
    return (K)0;
}
void* loop(void* vargs)
{
    J j = 0;
    sd1(d, qdisp);
    while(j++) {
        sleep(1);
        write(d, &j, sizeof(J));
    }
    return NULL;
}
K init(K cb)
{
    d = eventfd(1, 0);
    int err = pthread_create(&tid, NULL, &loop, NULL);
    return (K)0;
}

回复于 2024-04-27T06:00:37+08:00

C库从BG线程调用kdb函数

2 回答

相关问题