diff --git a/loky/backend/queues.py b/loky/backend/queues.py
index f2cbf9bc..b47e5cd5 100644
--- a/loky/backend/queues.py
+++ b/loky/backend/queues.py
@@ -54,7 +54,10 @@ def __init__(self, maxsize=0, reducers=None, ctx=None):
             # For use by concurrent.futures
             self._ignore_epipe = False
 
-            self._after_fork()
+            if sys.version_info >= (3, 9):
+                self._reset()
+            else:
+                self._after_fork()
 
             if sys.platform != 'win32':
                 util.register_after_fork(self, Queue._after_fork)
@@ -72,7 +75,10 @@ def __setstate__(self, state):
         (self._ignore_epipe, self._maxsize, self._reader, self._writer,
          self._reducers, self._rlock, self._wlock, self._sem,
          self._opid) = state
-        self._after_fork()
+        if sys.version_info >= (3, 9):
+            self._reset()
+        else:
+            self._after_fork()
 
     # Overload _start_thread to correctly call our custom _feed
     def _start_thread(self):