python
diff --git a/‎Lib/test/test_asyncio/test_futures.py
Copy file name to clipboardExpand all lines: Lib/test/test_asyncio/test_futures.py
+12Lines changed: 12 additions & 0 deletions b/‎Lib/test/test_asyncio/test_futures.py
Copy file name to clipboardExpand all lines: Lib/test/test_asyncio/test_futures.py
+12Lines changed: 12 additions & 0 deletions
diff --git a/‎Lib/test/test_asyncio/test_tasks.py
Copy file name to clipboardExpand all lines: Lib/test/test_asyncio/test_tasks.py
+15Lines changed: 15 additions & 0 deletions b/‎Lib/test/test_asyncio/test_tasks.py
Copy file name to clipboardExpand all lines: Lib/test/test_asyncio/test_tasks.py
+15Lines changed: 15 additions & 0 deletions
diff --git a/‎Misc/NEWS.d/next/Library/2017-08-01-09-32-58.bpo-31061.husAYX.rst
Copy file name to clipboard
+1Lines changed: 1 addition & 0 deletions b/‎Misc/NEWS.d/next/Library/2017-08-01-09-32-58.bpo-31061.husAYX.rst
Copy file name to clipboard
+1Lines changed: 1 addition & 0 deletions
diff --git a/‎Modules/_asynciomodule.c
Copy file name to clipboardExpand all lines: Modules/_asynciomodule.c
+4Lines changed: 4 additions & 0 deletions b/‎Modules/_asynciomodule.c
Copy file name to clipboardExpand all lines: Modules/_asynciomodule.c
+4Lines changed: 4 additions & 0 deletions
@@ -1,6 +1,7 @@
 """Tests for futures.py."""
 
 import concurrent.futures
+import gc
 import re
 import sys
 import threading
@@ -19,9 +20,11 @@
 def _fakefunc(f):
     return f
 
+
 def first_cb():
     pass
 
+
 def last_cb():
     pass
 
@@ -483,6 +486,15 @@ def test_future_iter_throw(self):
                           Exception("elephant"), Exception("elephant"))
         self.assertRaises(TypeError, fi.throw, list)
 
+    def test_future_del_collect(self):
+        class Evil:
+            def __del__(self):
+                gc.collect()
+
+        for i in range(100):
+            fut = self._new_future(loop=self.loop)
+            fut.set_result(Evil())
+
 
 @unittest.skipUnless(hasattr(futures, '_CFuture'),
                      'requires the C _asyncio module')
 
@@ -3,6 +3,7 @@
 import collections
 import contextlib
 import functools
+import gc
 import io
 import os
 import re
@@ -91,6 +92,20 @@ def setUp(self):
         self.loop.set_task_factory(self.new_task)
         self.loop.create_future = lambda: self.new_future(self.loop)
 
+    def test_task_del_collect(self):
+        class Evil:
+            def __del__(self):
+                gc.collect()
+
+        @asyncio.coroutine
+        def run():
+            return Evil()
+
+        self.loop.run_until_complete(
+            asyncio.gather(*[
+                self.new_task(self.loop, run()) for _ in range(100)
+            ], loop=self.loop))
+
     def test_other_loop_future(self):
         other_loop = asyncio.new_event_loop()
         fut = self.new_future(other_loop)
 
@@ -0,0 +1 @@
+Fixed a crash when using asyncio and threads.
@@ -972,6 +972,8 @@ FutureObj_dealloc(PyObject *self)
         }
     }
 
+    PyObject_GC_UnTrack(self);
+
     if (fut->fut_weakreflist != NULL) {
         PyObject_ClearWeakRefs(self);
     }
@@ -1846,6 +1848,8 @@ TaskObj_dealloc(PyObject *self)
         }
     }
 
+    PyObject_GC_UnTrack(self);
+
     if (task->task_weakreflist != NULL) {
         PyObject_ClearWeakRefs(self);
     }
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+Fixed a crash when using asyncio and threads.`
Original file line number	Diff line number	Diff line change
`@@ -972,6 +972,8 @@ FutureObj_dealloc(PyObject *self)`
`972`	`972`	`}`
`973`	`973`	`}`
`974`	`974`
	`975`	`+ PyObject_GC_UnTrack(self);`
	`976`	`+`
`975`	`977`	`if (fut->fut_weakreflist != NULL) {`
`976`	`978`	`PyObject_ClearWeakRefs(self);`
`977`	`979`	`}`
`@@ -1846,6 +1848,8 @@ TaskObj_dealloc(PyObject *self)`
`1846`	`1848`	`}`
`1847`	`1849`	`}`
`1848`	`1850`
	`1851`	`+ PyObject_GC_UnTrack(self);`
	`1852`	`+`
`1849`	`1853`	`if (task->task_weakreflist != NULL) {`
`1850`	`1854`	`PyObject_ClearWeakRefs(self);`
`1851`	`1855`	`}`