memory leak в multiprocessing

print(type(frame))

<class 'numpy.ndarray'>

from multiprocessing import Process, Queue
import cv2
import time


def worker(inputQueue, outputQueue):
  while True:
    if not inputQueue.empty():
      frame = inputQueue.get()
      time.sleep(0.1)


inputQueue = Queue(maxsize=1)
outputQueue = Queue(maxsize=1)

vs = cv2.VideoCapture(0)

p = Process(target=worker, args=(inputQueue, outputQueue))
p.daemon = True
p.start()
i = 0

while True:
  ret, frame = vs.read()
  if ret == True:
    i += 1
    if inputQueue.empty():
      inputQueue.put(frame)  # <--утечка тут!
    cv2.imshow("Camera", frame)

    if i == 100:
      print('Restart counter ' + str(i))
      i = 0

  if cv2.waitKey(1) & 0xFF == ord("q"):
    break

p.terminate()
vs.release()
cv2.destroyAllWindows()

from multiprocessing import Process, Queue
from pympler import muppy, summary
import numpy as np
import cv2
import time
import os
import array
import objgraph


def worker(inputQueue,):
	while True:
		if not inputQueue.empty():
			frame = inputQueue.get()

vs = cv2.VideoCapture(0)
i = 0

inputQueue = Queue()
p = Process(target=worker, args=(inputQueue,))
p.daemon = True
p.start()

while True:
	ret, frame = vs.read()
	if ret == True:
		
		if inputQueue.empty():
			inputQueue.put(frame)
		
		cv2.imshow("Camera", frame)

		i += 1
		if i == 300:
			i = 0
			summary.print_(summary.summarize(muppy.get_objects()))
			all_objects = muppy.get_objects()
			all_arrays = [obj for obj in all_objects if isinstance(obj, array.array)]
			objgraph.show_backrefs(all_arrays[0], filename='array.png')

	if cv2.waitKey(1) & 0xFF == ord("q"):
		break

p.terminate()
vs.release()
cv2.destroyAllWindows()

inputQueue.put(frame)

from multiprocessing import Process, Queue, Lock
# from pympler.tracker import SummaryTracker
import cv2
import subprocess

# При записи в файл будут потери от джепега, но это не страшно.
# если не жалко места в tmpfs, то можно сменить расширение на png.
img_file = 'tmp/screenshot.jpg'


def init_fs():
  #subprocess.call('sudo umount tmp', shell=True)
  #subprocess.call('sudo mount -t tmpfs -o size=20m tmpfs tmp', shell=True)
  subprocess.call('mkdir -p tmp', shell=True)




def worker(inputQueue, lock_obj, outputQueue):
  while True:
    if not inputQueue.empty():
      lock_obj.acquire()
      try:
        # frame = inputQueue.get()
        i = inputQueue.get()
        frame = cv2.imread(img_file)
      finally:
        lock_obj.release()

inputQueue = Queue(maxsize=1)
outputQueue = Queue(maxsize=1)
# Работу с диском ведем под блокировкой
lock_obj = Lock()

vs = cv2.VideoCapture(0)

p = Process(target=worker, args=(inputQueue, lock_obj, outputQueue))
p.daemon = True
p.start()
i = 0
# tracker = SummaryTracker()

init_fs()

while True:
  ret, frame = vs.read()
  if ret == True:
    lock_obj.acquire()
    try:
      cv2.imwrite(img_file, frame)
    finally:
      lock_obj.release()

    i += 1
    if inputQueue.empty():
      #inputQueue.put(frame)	# <--утечка тут!
      inputQueue.put(i)
    cv2.imshow("Camera", frame)

    if i == 100:
      # tracker.print_diff()
      i = 0

  if cv2.waitKey(1) & 0xFF == ord("q"):
    break

p.terminate()
vs.release()
cv2.destroyAllWindows()