feat(netutil): add async http request for http client

algorithm/lrucache.go

@@ -44,7 +44,7 @@ func (l *LRUCache[K, V]) Get(key K) (V, bool) {
 
 	node, ok := l.cache[key]
 	if ok {
-		l.moveToHead(node)
+		l.moveToTail(node)
 		return node.value, true
 	}
 
@@ -66,7 +66,7 @@ func (l *LRUCache[K, V]) Put(key K, value V) {
 		}
 	} else {
 		node.value = value
-		l.moveToHead(node)
+		l.moveToTail(node)
 	}
 	l.length = len(l.cache)
 }
@@ -79,7 +79,7 @@ func (l *LRUCache[K, V]) Delete(key K) bool {
 		delete(l.cache, key)
 		return true
 	}
-
+	l.length = len(l.cache)
 	return false
 }
 
@@ -112,7 +112,7 @@ func (l *LRUCache[K, V]) deleteNode(node *lruNode[K, V]) K {
 	return node.key
 }
 
-func (l *LRUCache[K, V]) moveToHead(node *lruNode[K, V]) {
+func (l *LRUCache[K, V]) moveToTail(node *lruNode[K, V]) {
 	if l.tail == node {
 		return
 	}

netutil/http.go

@@ -221,6 +221,22 @@ func (client *HttpClient) SendRequest(request *HttpRequest) (*http.Response, err
 	return resp, nil
 }
 
+// AsyncSendRequest send http request with goroutine, pop response and error to channels
+func (client *HttpClient) AsyncSendRequest(request *HttpRequest, respChan chan *http.Response, errChan chan error) {
+	go func() {
+		defer func() {
+			if err := recover(); err != nil {
+				errChan <- fmt.Errorf("%v", err)
+			}
+		}()
+		resp, err := client.SendRequest(request)
+		if err != nil {
+			errChan <- err
+		}
+		respChan <- resp
+	}()
+}
+
 // DecodeResponse decode response into target object.
 // Play: https://go.dev/play/p/jUSgynekH7G
 func (client *HttpClient) DecodeResponse(resp *http.Response, target any) error {

netutil/http_test.go

@@ -373,6 +373,45 @@ func TestSendRequestWithFilePath(t *testing.T) {
 	}
 }
 
+func TestHttpClient_AsyncSendRequest(t *testing.T) {
+	t.Parallel()
+
+	assert := internal.NewAssert(t, "TestHttpClient_Get")
+
+	request := &HttpRequest{
+		RawURL: "https://jsonplaceholder.typicode.com/todos/1",
+		Method: "GET",
+	}
+
+	httpClient := NewHttpClient()
+	respCh := make(chan *http.Response, 20)
+	errCh := make(chan error, 20)
+	for i := 0; i < 50; i++ {
+		httpClient.AsyncSendRequest(request, respCh, errCh)
+	}
+	for i := 0; i < 50; i++ {
+		select {
+		case resp := <-respCh:
+			type Todo struct {
+				UserId    int    `json:"userId"`
+				Id        int    `json:"id"`
+				Title     string `json:"title"`
+				Completed bool   `json:"completed"`
+			}
+			var todo Todo
+			err := httpClient.DecodeResponse(resp, &todo)
+			if err != nil {
+				t.FailNow()
+			}
+			assert.Equal(1, todo.Id)
+		case err := <-errCh:
+			if err != nil {
+				t.Log("net error: ", err.Error())
+			}
+		}
+	}
+}
+
 func TestProxy(t *testing.T) {
 	config := &HttpClientConfig{
 		HandshakeTimeout: 20 * time.Second,