Merge pull request #25395 from taosdata/fix/limitIdxMaxThread3
limit index bg thread
This commit is contained in:
commit
206280e529
|
@ -26,6 +26,8 @@
|
||||||
#include "tsched.h"
|
#include "tsched.h"
|
||||||
|
|
||||||
#define INDEX_NUM_OF_THREADS 5
|
#define INDEX_NUM_OF_THREADS 5
|
||||||
|
#define INDEX_MAX_NUM_OF_THREADS 10
|
||||||
|
|
||||||
#define INDEX_QUEUE_SIZE 200
|
#define INDEX_QUEUE_SIZE 200
|
||||||
|
|
||||||
#define INDEX_DATA_BOOL_NULL 0x02
|
#define INDEX_DATA_BOOL_NULL 0x02
|
||||||
|
@ -61,6 +63,7 @@ static void indexDestroy(void* sIdx);
|
||||||
void indexInit(int32_t threadNum) {
|
void indexInit(int32_t threadNum) {
|
||||||
indexThreads = threadNum;
|
indexThreads = threadNum;
|
||||||
if (indexThreads <= 1) indexThreads = INDEX_NUM_OF_THREADS;
|
if (indexThreads <= 1) indexThreads = INDEX_NUM_OF_THREADS;
|
||||||
|
if (indexThreads >= INDEX_MAX_NUM_OF_THREADS) indexThreads = INDEX_MAX_NUM_OF_THREADS;
|
||||||
}
|
}
|
||||||
void indexEnvInit() {
|
void indexEnvInit() {
|
||||||
// refactor later
|
// refactor later
|
||||||
|
|
Loading…
Reference in New Issue