[eventlet-deprecation] Remove eventlet usage in `BatchNotifier
`
Related-Bug: #2087953 Change-Id: Ia88dccdd4e6385dbb86fff8e531c74bf68479cb0
This commit is contained in:
parent
9b7662e951
commit
13522f295c
@ -10,16 +10,16 @@
|
||||
# License for the specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
import queue
|
||||
import threading
|
||||
|
||||
import eventlet
|
||||
import time
|
||||
|
||||
from neutron.common import utils
|
||||
|
||||
|
||||
class BatchNotifier:
|
||||
def __init__(self, batch_interval, callback):
|
||||
self._pending_events = eventlet.Queue()
|
||||
self._pending_events = queue.Queue()
|
||||
self.callback = callback
|
||||
self.batch_interval = batch_interval
|
||||
self._mutex = threading.Lock()
|
||||
@ -58,7 +58,7 @@ class BatchNotifier:
|
||||
self._notify()
|
||||
# sleeping after send while holding the lock allows
|
||||
# subsequent events to batch up
|
||||
eventlet.sleep(self.batch_interval)
|
||||
time.sleep(self.batch_interval)
|
||||
|
||||
utils.spawn_n(synced_send)
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user