マルチスレッドプログラミング相談室 その６

30 名前：デフォルトの名無しさん mailto:sage [2007/08/17(金) 22:04:00 ] 続き public T Dequeue() { int current; int next; do { Thread.MemoryBarrier(); current = m_tail; if (current == m_head) return null; next = NextIndex(current); } while (Interlocked.CompareExchange(ref m_tail, next, current) != current); T value; while ((value = m_buffer[current]) == null) Wait(); m_buffer[current] = null; Thread.MemoryBarrier(); return value; } private int NextIndex(int current) { return ++current == m_buffer.Length ? 0 : current; } private static void Wait() { if (s_multiProcsessors) Thread.SpinWait(400); else Thread.Sleep(0); Thread.MemoryBarrier(); } } もうだめかもorz

---

---

[ 続きを読む ] / [ 携帯版 ]

read.cgi ver5.27 [feat.BBS2 +1.6] / e.0.2 (02/09/03) / eucaly.net products.
担当:undef