1

アプリケーションで 2 つの mysql オブジェクトを使用しています。スレッドを終了する前に、 mysql_thread_endを 1 回だけ呼び出す必要があります。スレッドを終了する前に呼び出す関数/コールバックはありますか?

サンプルプログラム添付

using namespace std;
class MySql
{
public:
    MySql()
    {
        mysql = mysql_init(NULL);
    }
    ~MySql()
    {
        if(mysql)
        {
            mysql_close(mysql);
        }
    // Wrong: this will clear thread specific values twice. it may lead to crash the application.   
       // mysql_thread_end();
    }
    int Connect(const char *host,
                       const char *user,
                       const char *passwd,
                       const char *db,
                       unsigned int port,
                       const char *unix_socket,
                       unsigned long clientflag)
    {
        if(!mysql_real_connect(mysql, host,user, 
                            passwd, db, port, unix_socket, clientflag))
        {  
        return 1;
        }
        return 0;
    }
    int Execute(const char *query)
    {     
        int status = mysql_query(mysql, query);
        return status;
    }
private:
    MYSQL * mysql;
};

void createthreads();
static void StartThread(void * Arg);

int main(int argc, _TCHAR* argv[])
{
    int i = mysql_library_init(0, NULL, NULL);
    createthreads();    
    mysql_library_end();
    return 0;
}

void createthreads()
{  
    PRThread *thread;

    thread = PR_CreateThread(PR_USER_THREAD, StartThread, (void *)NULL, PR_PRIORITY_NORMAL, PR_GLOBAL_THREAD, PR_JOINABLE_THREAD, 0);
    //Sleep(2000);
    PR_JoinThread(thread);   
}

void StartThread(void * Arg)
{
    MySql mysqlsrc;
    MySql mysqldest;

    //Production server
    if(!mysqlsrc.Connect("localhost","root", "root", NULL, 3306, NULL, 0))
    {
        cout<<"Connection to Src Failed";
        return;
    }

    //Test Server
    if(!mysqldest.Connect("localhost","root", "root", NULL, 3306, NULL, 0))
    {
        cout<<"Connection to Destn Failed";
        return;
    }

    /// Sync databases.     
}
4

2 に答える 2

0

スレッド固有のデータ用の標準の pthread 機能により、スレッド固有のデータ デストラクタを登録できるため、一種の「pthread 終了フック」の実装に使用できます。

そのフックは を呼び出すことができmysql_thread_end()、残りのコードはこれを意識する必要はありません:

using namespace std;

// --> XXX WARNING UNTESTED AND ERROR CHECKING OMITTED XXX <----

namespace {
    pthread_key_t    key;
    pthread_key_once key_once = PTHREAD_ONCE_INIT;

    void cleanup(void *dummy)  // called at thread termination
    {
        mysql_thread_end();
    }
    void key_init()            // called pthread_once and only once
    {
        (void)pthread_key_create(&key, mycleanup);
    }
    void workaround_bz66740()  // call after you know mysql_thread_init has been called
    {
        (void)pthread_once(&key_once, key_init);
        (void)pthread_setspecific(key, (const void *)1);
    }
}

class MySql
{
public:
    MySql()
    {
        mysql = mysql_init(NULL);
        workaround_bz66740();
    }
    ....

補足: MySQL 変更要求 #66740で明確に説明されているように、MySQL リソースを明示的にクリーンアップする必要があるという事実は負担が大きく、残念です。

于 2013-05-23T13:24:40.807 に答える