add max thread (#1153)

* add max thread

* fix log

Author: hellertang

tencentcloud/data_source_tc_instances_set.go

@@ -334,7 +334,7 @@ func dataSourceTencentCloudInstancesSetRead(d *schema.ResourceData, meta interfa
 		instanceList = append(instanceList, mapping)
 		ids = append(ids, *instance.InstanceId)
 	}
-
+	log.Printf("[DEBUG]%s set instance attribute finished", logId)
 	d.SetId(helper.DataResourceIdsHash(ids))
 	err := d.Set("instance_list", instanceList)
 	if err != nil {
@@ -348,6 +348,8 @@ func dataSourceTencentCloudInstancesSetRead(d *schema.ResourceData, meta interfa
 			return err
 		}
 	}
+
+	log.Printf("[DEBUG]%s all operate finished", logId)
 	return nil
 
 }

tencentcloud/service_tencentcloud_cvm.go

@@ -153,7 +153,9 @@ func (me *CvmService) DescribeInstanceInParallelByFilter(ctx context.Context, fi
 
 	num := int(*total) / limit
 
-	g := NewGoRoutine(num + 1)
+	maxConcurrentNum := 50
+	//g := NewGoRoutine(num + 1)
+	g := NewGoRoutine(maxConcurrentNum)
 	wg := sync.WaitGroup{}
 
 	var instanceSetList = make([]interface{}, num+1)
@@ -190,14 +192,17 @@ func (me *CvmService) DescribeInstanceInParallelByFilter(ctx context.Context, fi
 			instanceSetList[value] = response.Response.InstanceSet
 
 			wg.Done()
+			log.Printf("[DEBUG]%s thread %d finished", logId, value)
 		}
 		g.Run(goFunc)
 	}
 	wg.Wait()
 
+	log.Printf("[DEBUG]%s DescribeInstance requet finished", logId)
 	for _, v := range instanceSetList {
 		instances = append(instances, v.([]*cvm.Instance)...)
 	}
+	log.Printf("[DEBUG]%s transfer Instance finished", logId)
 	return
 }