def test_join_all(self):
        session_threads = []

        def _side_effect(*args, **kwargs):
            thread = mock.MagicMock()
            session_threads.append(thread)
            return thread

        with mock.patch.object(thread, 'SessionThread',
                               side_effect=_side_effect):
            pool.Pool(None).join_all()

        for st in session_threads:
            st.join.assert_called_once_with()
Ensure that all threads are joined properly.
dataset/ETHPy150Open sigmavirus24/requests-toolbelt/tests/threaded/test_pool.py/TestPool.test_join_all