C# multithreading

Question

아래 코드를 살펴보십시오. 이것이 ENTIRE 클래스라고 가정합니다. 나는 어떤 코드도 생략하지 않았다. 이것은 말 그대로 문자 그대로입니다.

주 프로그램 루프에서이 클래스를 인스턴스화하고 myExample.Add (무엇이든)를 수시로 호출하면 Dequeue() 및 Enqueue()를 잠그지 않아 발생하는 문제에 대해 걱정할 필요가 있습니까?

public class Example<T> 
{ 
    private Queue<T> q = new Queue<T>(); 

    public Example() 
    { 
     new Thread(() => 
     { 
      while (true) 
      { 
       if (this.q.Count > 0) 
       { 
        var item = this.q.Dequeue(); 
       } 
       Thread.Sleep(1); 
      } 
     }).Start(); 
    } 

    public void Add(T val) 
    { 
     this.q.Enqueue(val); 
    } 
} 

this.q.Enqueue (val)가 this.q.Dequeue()와 동시에 호출되면 어떻게됩니까?

Answer 1

에 따라 다릅니다. :) 여러개의 쓰레드를 가진 Example을 호출하면 큐의 수를 확인하는 것과 dequeue를 비교하는 사이에 경쟁 조건이 생깁니다. 당신은 당신이 이륙하든 상관하지 않기 때문에 예를 들어 ...

T1 Call Example 
T2 Call Example 
T2 check Q.Count > 0 (yes) 
T1 check Q.count > 0 (yes) 
T2 dequeue 
T1 dequeue OOPS! 

여러 스레드 예를 호출하지 않는 경우

, 당신은 당신이 뭔가를 벗어 것만 아무 문제가 없습니다. 이륙 한 것을 신경 쓰면 Add와 Example 사이의 경쟁 조건이 다시 문제가됩니다.

Answer 2

난 당신이

this.q.Enqueue(val); 

을 의미

this.queue.Enqueue(val); 

에 의해 가정?

그렇다면 어떤 종류의 잠금을 수행해야합니다. 컬렉션은 본질적으로 스레드로부터 안전하지 않습니다. 항상 한 스레드에서 제거하고 항상 다른 스레드에서 추가한다고 생각하면 문제가 없을 수도 있지만 안전하지 않은 이유는 무엇입니까?

Answer 3

크리스

개인 정적 필드

readonly static object lockObject = new object(); 

당신의 람다 루프 밖에서 넣어위한

lock(lockObject) 
{ 
    //do stuff 
} 

와 디큐와 인큐을 둘러싸 추가

Answer 4

당신이있어 이후 큐를 Dequeue 메소드를 통해 큐에 쓰면 큐를 잠글 수 있습니다. 큐는 다중 판독기에서는 스레드로부터 안전하지만 복수 작성자에서는 사용할 수 없습니다. Queue thread safety.

Answer 5

안전하다고 생각하는 이유가 표시되지 않습니다.

제 걱정/가정 (두 개의 서로 다른 스레드에서) 동시에 대기열에 넣기와 대기열에 들어감을 입력하면 대기열 인스턴스의 내부 상태가 손상 될 수 있습니다.

Answer 6

MSDN 대기열이 스레드로부터 안전하지 않습니다 말한다 : 당신이 작동 할 것으로 예상되는 경우 http://msdn.microsoft.com/en-us/library/7977ey2c.aspx

Answer 7

짧은 버전은 당신에게 큐 해야 동기화에 액세스 할 수 있습니다. Count/Dequeue에는 명백한 스레드 레이스가 있지만 더 중요한 것은 이 없습니다. 작업이 보장됩니다. 내부 상태가 일 일 수 있으며 손상 될 수 있습니다.

결국 스레드를 종료하는 방법을 원할 것입니다.

차단 대기열을 작성하려면 여기를 참조하십시오. Creating a blocking Queue<T> in .NET.

Answer 8

대기열을 수정하는 별도의 스레드를 명시 적으로 작성 중이므로 호출하는 스레드에 관계없이 Add()를 호출하는 것이 안전하지 않습니다.

"if"문 블록은 q.Count를 호출해도 안전하지 않으므로 lock()을 수행 한 다음 Add() 메서드에서 다시 잠글 필요가 있습니다.