Come terminare un thread gestito bloccato nel codice non gestito?

Question

Ho un thread gestito che è in attesa, bloccato, in un codice non gestito (in particolare, su una chiamata a NamedPipeServerStream.WaitForConnection() che chiama in modo superfluo nel codice non gestito e fa non offre un timeout).

Voglio chiudere il thread in modo ordinato.

Thread.Abort() non ha alcun effetto fino a quando il codice non ritorna al dominio gestito, che non eseguirà finché un client non effettua una connessione, che non possiamo attendere).

Ho bisogno di un modo per "scioccarlo" dal codice non gestito; o un modo per uccidere il filo anche mentre si trova in una terra non gestita.

Answer 1

Hai provato a utilizzare il metodo non bloccante NamedPipeServerStream.BeginWaitForConnection?

using (NamedPipeServerStream stream = ...) 
{ 
    var asyncResult = stream.BeginWaitForConnection(null, null); 

    if (asyncResult.AsyncWaitHandle.WaitOne(5000)) 
    { 
     stream.EndWaitForConnection(asyncResult); 
     // success 
    } 
} 

Non devono necessariamente utilizzare un timeout fisso. È possibile utilizzare un ManualResetEvent per segnalare quando il filo deve smettere di aspettare per il collegamento:

ManualResetEvent signal = new ManualResetEvent(false); 

using (NamedPipeServerStream stream = ...) 
{ 
    var asyncResult = stream.BeginWaitForConnection(_ => signal.Set(), null); 

    signal.WaitOne(); 
    if (asyncResult.IsCompleted) 
    { 
     stream.EndWaitForConnection(asyncResult); 
     // success 
    } 
} 

// in other thread 
void cancel_Click(object sender, EventArgs e) 
{ 
    signal.Set(); 
} 

Answer 2

Non v'è alcun modo per "ordinatamente" arrestare un filo dall'esterno, se quel filo è in esecuzione il codice unmannaged. Ci sono un paio di modi per interrompere bruscamente il thread, ma probabilmente non è quello che vuoi.

Utilizzare invece BeginWaitForConnection.

Answer 3

In realtà, la soluzione che ho usato (che mi è venuto in mente mentre stavo scrivendo la domanda), era, dopo aver interrotto tutti i thread, solo per creare (e disporre immediatamente) un client per ogni thread.

threads.ForEach(thread=> thread.Abort()); 
    threads.ForEach(thread=> 
       { 
        var client = new PipeClient(ServiceName); 
        client.Connect(); 
        client.Dispose(); 
       }); 

Con la connessione, restituisce al codice gestito, e l'interruzione() calci (il filo catture ThreadAbortException e si pulisce)

Questo non funziona per il caso generale (cioè, la domanda posta nel titolo), ma funziona per me ...