<div id="readability-page-1" class="page"><div id="content">
						<article id="post-6041">
				<div>
<p>
  하나의 스레드에서 큐에 데이터를 넣고 다른 쓰레드에서 큐에서 데이터를 꺼내는 간단한 예제 코드입니다. 
</p>



<p>
  아래 링크를 참고했습니다. 
</p>



<p><a href="https://docs.python.org/3/library/queue.html">https://docs.python.org/3/library/queue.html</a></p>



<p>
  2022. 09. 03  최초작성
</p>



<p>
  2023. 01. 21  큐 모듈 변경.
</p>







<pre><code>import threading
from multiprocessing import Queue


def producer():

    count = 0
    while True:

        lock.acquire() # 전역 변수 접근을 금지합니다.

        if not q.full(): # 큐가 꽉차지 않았다면

            count = count +1
            q.put_nowait(count) # 큐에 데이터를 넣습니다.
            print(f'push item {count}')
           

        lock.release() # 이제 전역 변수 접근을 할 수 있습니다.

        if count == 10: break

    print('thread 1 exit')


def consumer():

    while True:

        # acquire 대신에 with를 사용하면 release를 적을 필요가 없습니다. 
        with lock:  # 전역 변수 접근을 금지합니다.

            if not q.empty(): # 큐가 비어있지 않다면
                item = q.get_nowait() # 큐에서 데이터를 꺼냅니다.
                print(f'get item {item}')

            if item == 10: break

    print('thread 2 exit')



# 큐의 최대 크기는 3입니다.
q = Queue(3)

lock = threading.Lock()  # 뮤텍스 객체를 전역으로 선언하여 스레드간에 공유하도록 합니다.


t1 = threading.Thread(target=producer) # 큐에 데이터를 넣는 스레드입니다.
t1.start()

t2 = threading.Thread(target=consumer) # 큐에서 데이터를 꺼내는 스레드입니다.
t2.start()

# 스레드가 종료하기를 대기합니다.
t1.join()
t2.join()


print('main exit')</code></pre>







<p>
  실행 결과입니다. 
</p>



<p>
  한 스레드에서 데이터를 큐에 넣고(push item) 다른 스레드에서 큐에서 데이터를 꺼내고(get item) 있습니다. 아래 결과에선 큐에 넣고 큐에서 꺼내는게 데이터 3개씩 번갈아 가면 발생하지만 스레드라서 이렇게 동작하지 않을 수도 있습니다.  
</p>



<figure><img data-lazy-fallback="1" data-attachment-id="6042" data-permalink="https://webnautes.blog/6041/word-image-6041-1/" data-orig-file="https://i0.wp.com/webnautes.blog/wp-content/uploads/2023/09/word-image-6041-1.png?fit=910%2C652&amp;ssl=1" data-orig-size="910,652" data-comments-opened="1" data-image-meta="{&quot;aperture&quot;:&quot;0&quot;,&quot;credit&quot;:&quot;&quot;,&quot;camera&quot;:&quot;&quot;,&quot;caption&quot;:&quot;&quot;,&quot;created_timestamp&quot;:&quot;0&quot;,&quot;copyright&quot;:&quot;&quot;,&quot;focal_length&quot;:&quot;0&quot;,&quot;iso&quot;:&quot;0&quot;,&quot;shutter_speed&quot;:&quot;0&quot;,&quot;title&quot;:&quot;&quot;,&quot;orientation&quot;:&quot;0&quot;}" data-image-title="word-image-6041-1" data-image-description="" data-image-caption="" data-medium-file="https://i0.wp.com/webnautes.blog/wp-content/uploads/2023/09/word-image-6041-1.png?fit=300%2C215&amp;ssl=1" data-large-file="https://i0.wp.com/webnautes.blog/wp-content/uploads/2023/09/word-image-6041-1.png?fit=910%2C652&amp;ssl=1" decoding="async" fetchpriority="high" width="910" height="652" src="https://i0.wp.com/webnautes.blog/wp-content/uploads/2023/09/word-image-6041-1.png?resize=910%2C652&amp;ssl=1" alt="" sizes="(max-width: 910px) 100vw, 910px" data-recalc-dims="1" data-old-src="https://i0.wp.com/webnautes.blog/wp-content/uploads/2023/09/word-image-6041-1.png?resize=910%2C652&amp;is-pending-load=1#038;ssl=1" data-lazy-srcset="https://i0.wp.com/webnautes.blog/wp-content/uploads/2023/09/word-image-6041-1.png?w=910&amp;ssl=1 910w, https://i0.wp.com/webnautes.blog/wp-content/uploads/2023/09/word-image-6041-1.png?resize=300%2C215&amp;ssl=1 300w, https://i0.wp.com/webnautes.blog/wp-content/uploads/2023/09/word-image-6041-1.png?resize=768%2C550&amp;ssl=1 768w"></figure>





</div> 

			</article>
			
		</div></div>

멈춤보단 천천히라도

webnautes

하나의 스레드에서 큐에 데이터를 넣고 다른 쓰레드에서 큐에서 데이터를 꺼내는 간단한 예제 코드입니다. 아래 링크를 참고했습니다. https://docs.python.org/3/library/queue.html 2022. 09. 03 최초작성 2023. 01. 21 큐 모듈 변경. 실행 결과입니다. 한 스레드에서 데이터를 큐에 넣고(push item) 다른 스레드에서 큐에서 데이터를 꺼내고(get item) 있습니다. 아래 결과에선 큐에 넣고 큐에서 꺼내는게 데이터 3개씩 번갈아 가면 발생하지만 스레드라서 이렇게… 더 보기 »Thread에서 사용한 Python Queue 간단한 예제
The post Thread에서 사용한 Python Queue 간단한 예제 first appeared on 멈춤보단 천천히라도.

Thread에서 사용한 Python Queue 간단한 예제

댓글