Revert "Consume threads of the number of nq (#24410)" (#24554)

This reverts commit 71a7fef5c5.

Signed-off-by: yah01 <yah2er0ne@outlook.com>

internal/querynodev2/tasks/scheduler.go

@@ -3,7 +3,6 @@ package tasks
 import (
 	"context"
 	"fmt"
-	"sync"
 
 	"go.uber.org/atomic"
 
@@ -26,9 +25,7 @@ type Scheduler struct {
 	queryProcessQueue chan *QueryTask
 	queryWaitQueue    chan *QueryTask
 
-	pool             *conc.Pool[any]
-	runningThreadNum int
-	cond             *sync.Cond
+	pool *conc.Pool[any]
 }
 
 func NewScheduler() *Scheduler {
@@ -42,7 +39,6 @@ func NewScheduler() *Scheduler {
 		// queryProcessQueue: make(chan),
 
 		pool: conc.NewPool[any](maxReadConcurrency, ants.WithPreAlloc(true)),
-		cond: sync.NewCond(&sync.Mutex{}),
 	}
 }
 
@@ -155,23 +151,7 @@ func (s *Scheduler) processAll(ctx context.Context) {
 }
 
 func (s *Scheduler) process(t Task) {
-	s.cond.L.Lock()
-	for s.runningThreadNum >= s.pool.Cap() {
-		s.cond.Wait()
-	}
-	s.runningThreadNum += t.Weight()
-	s.cond.L.Unlock()
-
 	s.pool.Submit(func() (any, error) {
-		defer func() {
-			s.cond.L.Lock()
-			defer s.cond.L.Unlock()
-			s.runningThreadNum -= t.Weight()
-			if s.runningThreadNum < s.pool.Cap() {
-				s.cond.Broadcast()
-			}
-		}()
-
 		metrics.QueryNodeReadTaskConcurrency.WithLabelValues(fmt.Sprint(paramtable.GetNodeID())).Inc()
 
 		err := t.Execute()

internal/querynodev2/tasks/task.go

@@ -25,7 +25,6 @@ type Task interface {
 	Done(err error)
 	Canceled() error
 	Wait() error
-	Weight() int
 }
 
 type SearchTask struct {
@@ -236,10 +235,6 @@ func (t *SearchTask) Wait() error {
 	return <-t.notifier
 }
 
-func (t *SearchTask) Weight() int {
-	return int(t.nq)
-}
-
 func (t *SearchTask) Result() *internalpb.SearchResults {
 	return t.result
 }