Cómo detectar el acceso de subprocesos cruzados en .NET (aplicar la afinidad de subprocesos)?

Question

Estoy escribiendo una estructura de datos especial que estará disponible en una biblioteca .NET y una de las características de esta estructura de datos es que será segura para hilos, siempre que solo un hilo le escriba datos, y solo un hilo lo lea datos del mismo (el hilo del lector y el hilo del escritor pueden ser diferentes).

La pregunta es ¿cómo puedo exigir que todas las operaciones de lectura se ejecuten con el mismo hilo?

Mi solución sería capturar el System.Threading.Thread.ManagedThreadID y almacenarlo en un miembro privado en la primera lectura. Luego, en lecturas posteriores, compruebe el ManagedThreadID contra el guardado y si son diferentes para arrojar una excepción.

¿Eso es suficiente o hay un mecanismo diferente más confiable para hacer esto?

Nota: No es un requisito que esta biblioteca sea utilizable sin un contexto Windows.Forms ..

Answer 1

Cuando me encuentro con esta situación utilizo una clase que escribí llamada ThreadAffinity. Todo el propósito es registrar el hilo actual y lanzar accesos no válidos desde un hilo diferente. Tienes que hacer el cheque manualmente, pero encapsula la pequeña cantidad de trabajo para ti.

class Foo { 
    ThreadAffinity affinity = new ThreadAffinity(); 

    public string SomeProperty { 
    get { affinity.Check(); return "Somevalue"; } 
    } 
} 

Clase

[Immutable] 
public sealed class ThreadAffinity 
{ 
    private readonly int m_threadId; 

    public ThreadAffinity() 
    { 
     m_threadId = Thread.CurrentThread.ManagedThreadId; 
    } 

    public void Check() 
    { 
     if (Thread.CurrentThread.ManagedThreadId != m_threadId) 
     { 
      var msg = String.Format(
       "Call to class with affinity to thread {0} detected from thread {1}.", 
       m_threadId, 
       Thread.CurrentThread.ManagedThreadId); 
      throw new InvalidOperationException(msg); 
     } 
    } 
} 

Blog post sobre el tema:

• http://blogs.msdn.com/jaredpar/archive/2008/02/22/thread-affinity.aspx

Answer 2

Podría no requiere la lectura y escritura de métodos toman un ID de hilo o hilo? Luego puede comparar con el que lo llamó primero, y si no coincide, lanzar una excepción o devolver un código de error, o ignorar la solicitud.

De lo contrario, lo que propone debe funcionar también. Solo necesita comparar los identificadores de subprocesos.

Answer 3

En lugar de comparar ID de hilo, debe almacenar el ambient Thread en su clase durante la construcción.

class SingleThreadedClass 
{ 
    private Thread ownerThread; 

    public SingleThreadedClass() 
    { 
     this.ownerThread = Thread.CurrentThread; 
    } 

    public void Read(...) 
    { 
     if (Thread.CurrentThread != this.ownerThread) 
      throw new InvalidOperationException(); 
    } 

    public void TakeOwnership() 
    { 
     this.ownerThread = Thread.CurrentThread; 
    } 
}