Azure Blob and Queue Thread Safety

Question

Necesito ayuda para entender la seguridad de subprocesos en las clases azules CloudBlobClient, CloudQueueClient y CloudBlob.

Estoy desarrollando un rol de trabajador que incluye múltiples procesadores de trabajo independientes donde cada uno de estos procesadores de trabajos lee de una cola específica y escribe/actualiza en algunos contenedores de blobs que pueden ser los mismos.

Quiero asegurarme de que estos procesadores de trabajo no se pise el uno al otro.

1> ¿Cómo puedo asegurarme de que este sea el caso sin utilizar ningún tipo de bloqueo? Si asigno CloudBlobClient y CloudQueueClient por separado a cada uno de mis procesadores de trabajo (quienes viven en el mismo proceso), es suficiente decir que son independientes entre sí y porque cada procesador de trabajo usa una instancia de cliente separada, no se ejecutarán el uno al otro en absoluto?

2> En el mismo procesador de trabajos, si intento tener paralelismo en CloudBlobClient usando Parallel.ForEach para decir call GetBlobReference o UploadText en paralelo, ¿necesito incorporar algún tipo de sincronización o estos métodos son seguros para subprocesos? La documentación de Azure dice que no, pero la mayoría de los ejemplos que he visto en línea no parecen aplicar ningún tipo de mecanismo de sincronización en estos métodos. ¿Cuál es la mejor manera de lograr esto? Me refiero a la mejor manera de usar un CloudBlobClient y llamar a GetBlobReference o UploadText en paralelo?

Answer 1

que tenía un aspecto en el CloudBlobClientdocumentation on MSDN y lo que dice es:

estáticos públicos (Shared en Visual Basic) de este tipo son seguros para subprocesos. No se garantiza que ningún miembro de instancia sea seguro para subprocesos.

Como no es un miembro estático, no se garantiza que sea seguro para subprocesos. Si quiere asegurarse de no quedar atrapado por ningún problema de subprocesamiento que la MS haya perdido en la biblioteca del cliente de almacenamiento, entonces sí debe asegurarse de que cada subproceso tenga su propio cliente (tal vez crear una variable ThreadStatic) .

Habiendo dicho eso, he utilizado CloudBlobClient para cargar varios elementos en un Parallel.ForEach sin que cause ningún problema.

Answer 2

La documentación de un randomly chosen function dice "Cualquier miembro estático estático ... los miembros de este tipo son seguros para subprocesos. No se garantiza que ninguno de los miembros de la instancia sea seguro para subprocesos", pero supongo que es un texto repetitivo porque alguien podría No te molestes en pensar sobre eso. Le sugiero que examine las clases usando Reflector, pero esperaría que estuvieran bien porque todas las clases a las que se refiere son solo repositorios de propiedades que terminan en solicitudes HTTP REST cuando realiza una llamada como UploadText. Siempre y cuando no cambies las propiedades de un objeto en diferentes hilos (y no creo que necesites - crear una CloudBlobReference para cada iteración de tu Parrallel.ForEach) entonces creo que estarás a salvo.