| 78 | raise NotImplementedError |
| 79 | |
| 80 | def __init__(self, group=None, target=None, name=None, args=(), kwargs=None, |
| 81 | *, daemon=None): |
| 82 | assert group is None, 'group argument must be None for now' |
| 83 | count = next(_process_counter) |
| 84 | self._identity = _current_process._identity + (count,) |
| 85 | self._config = _current_process._config.copy() |
| 86 | self._parent_pid = os.getpid() |
| 87 | self._parent_name = _current_process.name |
| 88 | self._popen = None |
| 89 | self._closed = False |
| 90 | self._target = target |
| 91 | self._args = tuple(args) |
| 92 | self._kwargs = dict(kwargs) if kwargs else {} |
| 93 | self._name = name or type(self).__name__ + '-' + \ |
| 94 | ':'.join(str(i) for i in self._identity) |
| 95 | if daemon is not None: |
| 96 | self.daemon = daemon |
| 97 | _dangling.add(self) |
| 98 | |
| 99 | def _check_closed(self): |
| 100 | if self._closed: |