diff options
| author | Richard Oudkerk <shibturn@gmail.com> | 2012-06-18 16:47:52 (GMT) |
|---|---|---|
| committer | Richard Oudkerk <shibturn@gmail.com> | 2012-06-18 16:47:52 (GMT) |
| commit | d69cfe88eae5b177b1aaf51c39e85fb92c34cf22 (patch) | |
| tree | 43151241e2aab605f65e3634affd630ea6e084a3 /Lib/multiprocessing/dummy | |
| parent | 0f884273b0319272ca32d529af5c761d6dfa8a34 (diff) | |
| download | cpython-d69cfe88eae5b177b1aaf51c39e85fb92c34cf22.zip cpython-d69cfe88eae5b177b1aaf51c39e85fb92c34cf22.tar.gz cpython-d69cfe88eae5b177b1aaf51c39e85fb92c34cf22.tar.bz2 | |
Issue #15064: Implement context manager protocol for multiprocessing types
Diffstat (limited to 'Lib/multiprocessing/dummy')
| -rw-r--r-- | Lib/multiprocessing/dummy/connection.py | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/Lib/multiprocessing/dummy/connection.py b/Lib/multiprocessing/dummy/connection.py index af10579..874ec8e 100644 --- a/Lib/multiprocessing/dummy/connection.py +++ b/Lib/multiprocessing/dummy/connection.py @@ -53,6 +53,12 @@ class Listener(object): address = property(lambda self: self._backlog_queue) + def __enter__(self): + return self + + def __exit__(self, exc_type, exc_value, exc_tb): + self.close() + def Client(address): _in, _out = Queue(), Queue() @@ -85,3 +91,9 @@ class Connection(object): def close(self): pass + + def __enter__(self): + return self + + def __exit__(self, exc_type, exc_value, exc_tb): + self.close() |