MySQL數(shù)據(jù)庫(kù)多線程編程是一種高效的并發(fā)處理方式，它可以提高數(shù)據(jù)庫(kù)的處理速度和吞吐量。下面通過(guò)一個(gè)實(shí)例來(lái)展示MySQL數(shù)據(jù)庫(kù)多線程編程的應(yīng)用。

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <mysql.h>
#define THREAD_NUM 5
#define SQL_STATEMENT "SELECT * FROM customers;"
void* thread_func(void* arg) {
int tid = *(int*)arg;
printf("Thread %d is running...\n", tid);
MYSQL* conn = mysql_init(NULL); // 初始化MySQL連接
mysql_real_connect(conn, "localhost", "root", "password", "database", 0, NULL, 0); // 連接到MySQL
mysql_query(conn, SQL_STATEMENT); // 執(zhí)行查詢(xún)語(yǔ)句
MYSQL_RES* result = mysql_store_result(conn); // 存儲(chǔ)查詢(xún)結(jié)果
int num_fields = mysql_num_fields(result);
MYSQL_ROW row;
while ((row = mysql_fetch_row(result))) {
for (int i = 0; i< num_fields; i++) {
printf("%s\t", row[i]);
}
printf("\n");
}
mysql_free_result(result); // 釋放查詢(xún)結(jié)果
mysql_close(conn); // 關(guān)閉MySQL連接
printf("Thread %d is finished.\n", tid);
pthread_exit(NULL);
}
int main() {
pthread_t threads[THREAD_NUM];
int tids[THREAD_NUM];
for (int i = 0; i< THREAD_NUM; i++) {
tids[i] = i;
pthread_create(&threads[i], NULL, thread_func, &tids[i]); // 創(chuàng)建多個(gè)線程并執(zhí)行查詢(xún)
}
for (int i = 0; i< THREAD_NUM; i++) {
pthread_join(threads[i], NULL); // 等待所有線程結(jié)束
}
return 0;
}

上面的示例中，我們使用了MySQL C API來(lái)連接和操作MySQL數(shù)據(jù)庫(kù)。在主函數(shù)中，我們創(chuàng)建了多個(gè)線程，并傳遞線程ID和線程函數(shù)作為參數(shù)來(lái)執(zhí)行查詢(xún)操作。每個(gè)線程都會(huì)創(chuàng)建獨(dú)立的MySQL連接，并執(zhí)行查詢(xún)語(yǔ)句，最后釋放查詢(xún)結(jié)果和關(guān)閉MySQL連接。

如果您需要處理更復(fù)雜的數(shù)據(jù)庫(kù)操作，可以參考MySQL C API的官方文檔來(lái)編寫(xiě)自己的多線程應(yīng)用程序。