Lines Matching refs:self
26 def __init__(self):
31 self._values = []
32 self._load = None
33 self._running = _overlapped.CreateEvent(None, True, False, None)
34 self._stopped = _overlapped.CreateEvent(None, True, False, None)
36 _thread.start_new_thread(self._update_load, (), {})
38 def _update_load(self,
43 while _wait(self._running, 1000):
44 self._calculate_load()
46 _signal(self._stopped)
48 def _calculate_load(self,
96 if self._load is not None:
97 self._load = (self._load * LOAD_FACTOR_1
99 elif len(self._values) < NVALUE:
100 self._values.append(processor_queue_length)
102 self._load = sum(self._values) / len(self._values)
104 def close(self, kill=True):
105 self.__del__()
108 def __del__(self,
113 if self._running is not None:
115 _signal(self._running)
117 _wait(self._stopped, -1)
119 _close(self._running)
120 _close(self._stopped)
121 self._running = self._stopped = None
123 def getloadavg(self):
124 return self._load