问题一：如下代码中 bulkService.Add(bulkCreateRequest)这一行，其实是向一个切片中追加bulkCreateRequest，切片并不是线程安全的，因此在调用bulkService.Add的时候，会不会有线程安全问题，需不需要加互斥锁？

// 批量的方式新建一批文档,实时提交
func (c *Client) BulkCreateDocs(ctx context.Context, indexName string, docs []*BulkCreateDoc) (*elastic.BulkResponse, error) {
	bulkService := c.Client.Bulk().ErrorTrace(true)
	for _, doc := range docs {
		bulkCreateRequest := elastic.NewBulkCreateRequest().Index(indexName)
		if len(doc.ID) > 0 {
			bulkCreateRequest.Id(doc.ID)
		}
		if len(doc.Routing) > 0 {
			bulkCreateRequest.Routing(doc.Routing)
		}

		bulkService.Add(bulkCreateRequest)
	}
	return bulkService.Do(ctx)
}

// Add adds bulkable requests, i.e. BulkIndexRequest, BulkUpdateRequest,
// and/or BulkDeleteRequest.
func (s *BulkService) Add(requests ...BulkableRequest) *BulkService {
	s.requests = append(s.requests, requests...)
	return s
}

问题二：在批量创建文档，后台提交模式中。我们只需要构建bulkCreateRequest，然后调用Add方法。将这个request添加到一个channel中，但是我发现这chan是一个同步的channel，没有缓存区的。我本来以为是异步提交的时候，是将request提交到一个有缓存的channel中，从这个有缓存的channel中批量的拉取数据，写入ES。但是现在看不是这个样子的。
那么我的问题是：异步写入的时候，是如何提交给ES的呢？

// Add adds a single request to commit by the BulkProcessorService.
//
// The caller is responsible for setting the index and type on the request.
func (p *BulkProcessor) Add(request BulkableRequest) {
	p.requestsC <- request
}