Informix C++ Client SDK多线程连接异常及正确实现方式求助

问题根源 #

你的代码存在三个核心问题，导致连接异常、崩溃及输出不符合预期：

1. 缺少线程专属环境初始化：Informix C++类库在多线程模式下，每个线程必须先初始化本地资源上下文，否则进程级的全局资源会被线程竞争，引发连接冲突或崩溃。
2. 标准输出无锁竞争：cout是全局共享对象，多线程同时输出会导致输出混乱或被覆盖，表现为仅单个线程有输出。
3. 未设置独立会话标识：未对应ESQL-C的session-id机制，线程间可能出现会话资源冲突。

修复方案 #

1. 修正线程代码（添加环境初始化/清理、输出锁、会话ID设置） #

#include <mutex>
#include <it.h>
#include <string>
#include <iostream>
#include <thread>

std::mutex cout_mutex; // 全局输出锁，解决多线程输出竞争

void printArt(int i)
{
    // 初始化当前线程的Informix本地环境
    if (!ITStartup::InitializeThread()) {
        std::lock_guard<std::mutex> lock(cout_mutex);
        std::cerr << "线程[" << i << "]环境初始化失败" << std::endl;
        return;
    }

    ITDBInfo dbinfo;
    dbinfo.SetDatabase("eda");
    
    ITConnection conn;
    conn.Open(dbinfo);
    
    if (conn.Error()) {
        ITStartup::TerminateThread();
        return;
    }

    // 设置唯一会话ID，对应ESQL-C的session-id机制
    std::string session_sql = "SET SESSION ID '" + std::to_string(i) + "'";
    if (!conn.Execute(session_sql.c_str())) {
        std::lock_guard<std::mutex> lock(cout_mutex);
        std::cerr << "线程[" << i << "]设置会话ID失败" << std::endl;
        conn.Close();
        ITStartup::TerminateThread();
        return;
    }

    conn.SetTransaction(ITConnection::Begin);
    
    ITCursor cursor(conn);
    
    if (!cursor.Prepare("select first 1 * from a_table;")) {
        conn.SetTransaction(ITConnection::ABORT);
        conn.Close();
        ITStartup::TerminateThread();
        return;
    }

    if (!cursor.Open()) {
        conn.SetTransaction(ITConnection::ABORT);
        conn.Close();
        ITStartup::TerminateThread();
        return;
    }

    ITRow* row = nullptr;
    while ((row = cursor.NextRow()) != nullptr) {
        std::string col0 = row->Column(0)->Printable().Data();
        std::string col1 = row->Column(1)->Printable().Data();

        // 加锁保证输出完整不混乱
        std::lock_guard<std::mutex> lock(cout_mutex);
        std::cout << "[" << i << "] " << col0 << " | " << col1 << std::endl;

        row->Release();
    }

    conn.SetTransaction(ITConnection::Commit);
    conn.Close();

    // 清理当前线程的Informix本地环境
    ITStartup::TerminateThread();
    return;
}

int main()
{
    const constexpr int nthreads = 10;
    std::thread t[nthreads];
  
    for (int i = 0; i < nthreads; ++i) {
        t[i] = std::thread(printArt, i);
    }

    for (int i = 0; i < nthreads; ++i) {
        t[i].join();
    }

    return 0;
}

2. 修正编译链接参数 #

编译时必须定义_THREAD_SAFE宏，并链接pthread库，完整编译命令示例：

g++ -std=c++17 -D_THREAD_SAFE your_code.cpp -o your_app -l thsql -l thasf -l thgen -l thos -l ifgls -l ifglx -l thdmi -l thc++ -lpthread

关键说明 #

• ITStartup::InitializeThread()会为当前线程分配独立的Informix资源上下文，避免线程间共享连接状态，这是解决崩溃问题的核心。
• 执行SET SESSION ID语句是C++类库中实现ESQL-Csession-id功能的等价方式，确保每个线程的会话完全独立。
• 全局互斥锁cout_mutex解决了多线程输出竞争问题，保证每个线程的输出完整可见。

内容的提问来源于stack exchange，提问作者Luigi Roggio