(self, fun, *args, **kwargs)
| 440 | return self._create_dispatcher() |
| 441 | |
| 442 | def freeze_while(self, fun, *args, **kwargs): |
| 443 | clear_after = kwargs.pop('clear_after', False) |
| 444 | with self._mutex: |
| 445 | try: |
| 446 | return fun(*args, **kwargs) |
| 447 | finally: |
| 448 | if clear_after: |
| 449 | self._clear() |
| 450 | |
| 451 | def clear_tasks(self, ready=True): |
| 452 | with self._mutex: |