From: "Zac Medico" <zmedico@gentoo.org>
To: gentoo-commits@lists.gentoo.org
Subject: [gentoo-commits] proj/portage:master commit in: pym/portage/util/_eventloop/
Date: Mon, 16 Apr 2018 08:48:21 +0000 (UTC) [thread overview]
Message-ID: <1523868381.1ee8971ba1cb34e6b3cd3d5fda23066b24630e3a.zmedico@gentoo> (raw)
commit: 1ee8971ba1cb34e6b3cd3d5fda23066b24630e3a
Author: Zac Medico <zmedico <AT> gentoo <DOT> org>
AuthorDate: Mon Apr 16 08:29:36 2018 +0000
Commit: Zac Medico <zmedico <AT> gentoo <DOT> org>
CommitDate: Mon Apr 16 08:46:21 2018 +0000
URL: https://gitweb.gentoo.org/proj/portage.git/commit/?id=1ee8971b
EventLoop: eliminate thread safety from call_soon
The call_soon method is used heavily by asyncio.Task to execute
coroutine steps, so it's important to eliminate the overhead
associated with thread safety.
pym/portage/util/_eventloop/EventLoop.py | 20 ++++++++++++++------
1 file changed, 14 insertions(+), 6 deletions(-)
diff --git a/pym/portage/util/_eventloop/EventLoop.py b/pym/portage/util/_eventloop/EventLoop.py
index 38e735999..4ef600a5b 100644
--- a/pym/portage/util/_eventloop/EventLoop.py
+++ b/pym/portage/util/_eventloop/EventLoop.py
@@ -506,12 +506,17 @@ class EventLoop(object):
@return: an integer ID
"""
with self._thread_condition:
- source_id = self._call_soon_id = self._new_source_id()
- self._idle_callbacks[source_id] = self._idle_callback_class(
- args=args, callback=callback, source_id=source_id)
+ source_id = self._idle_add(callback, *args)
self._thread_condition.notify()
return source_id
+ def _idle_add(self, callback, *args):
+ """Like idle_add(), but without thread safety."""
+ source_id = self._call_soon_id = self._new_source_id()
+ self._idle_callbacks[source_id] = self._idle_callback_class(
+ args=args, callback=callback, source_id=source_id)
+ return source_id
+
def _run_idle_callbacks(self):
# assumes caller has acquired self._thread_rlock
if not self._idle_callbacks:
@@ -810,11 +815,14 @@ class EventLoop(object):
@return: a handle which can be used to cancel the callback
@rtype: asyncio.Handle (or compatible)
"""
- return self._handle(self.idle_add(
+ return self._handle(self._idle_add(
self._call_soon_callback(callback, args)), self)
- # The call_soon method inherits thread safety from the idle_add method.
- call_soon_threadsafe = call_soon
+ def call_soon_threadsafe(self, callback, *args):
+ """Like call_soon(), but thread safe."""
+ # idle_add provides thread safety
+ return self._handle(self.idle_add(
+ self._call_soon_callback(callback, args)), self)
def time(self):
"""Return the time according to the event loop's clock.
next reply other threads:[~2018-04-16 8:48 UTC|newest]
Thread overview: 61+ messages / expand[flat|nested] mbox.gz Atom feed top
2018-04-16 8:48 Zac Medico [this message]
-- strict thread matches above, loose matches on Subject: below --
2018-07-18 3:41 [gentoo-commits] proj/portage:master commit in: pym/portage/util/_eventloop/ Zac Medico
2018-07-17 19:27 Zac Medico
2018-07-17 19:07 Zac Medico
2018-06-27 3:05 Zac Medico
2018-05-26 20:22 Zac Medico
2018-05-25 3:15 Zac Medico
2018-05-13 16:58 Zac Medico
2018-05-07 0:27 Zac Medico
2018-04-19 6:41 Zac Medico
2018-04-19 6:16 Zac Medico
2018-04-18 21:52 Zac Medico
2018-04-17 18:24 Zac Medico
2018-04-17 18:02 Zac Medico
2018-04-17 6:24 Zac Medico
2018-04-17 0:53 Zac Medico
2018-04-16 6:43 Zac Medico
2018-04-16 0:03 Zac Medico
2018-04-15 22:32 Zac Medico
2018-04-09 1:27 Zac Medico
2018-04-08 22:08 Zac Medico
2018-04-08 21:37 Zac Medico
2018-04-08 21:18 Zac Medico
2018-04-07 20:20 Zac Medico
2017-05-05 18:47 Zac Medico
2013-02-25 23:53 Zac Medico
2013-01-04 3:39 Zac Medico
2012-12-31 3:16 Zac Medico
2012-12-28 1:44 Zac Medico
2012-12-28 1:36 Zac Medico
2012-12-27 2:39 Zac Medico
2012-12-27 2:31 Zac Medico
2012-11-22 12:23 Zac Medico
2012-09-26 2:26 Zac Medico
2012-08-22 16:23 Zac Medico
2012-08-22 5:39 Zac Medico
2012-02-18 4:04 Zac Medico
2012-02-17 23:23 Zac Medico
2012-02-17 22:17 Zac Medico
2012-02-17 10:31 Zac Medico
2012-02-17 10:20 Zac Medico
2012-02-17 9:29 Zac Medico
2012-02-17 6:29 Zac Medico
2012-02-17 6:04 Zac Medico
2012-02-17 3:08 Zac Medico
2012-02-16 21:43 Zac Medico
2012-02-16 21:35 Zac Medico
2012-02-16 4:58 Zac Medico
2012-02-16 4:41 Zac Medico
2012-02-14 16:27 Zac Medico
2012-02-14 3:06 Zac Medico
2012-02-14 1:23 Zac Medico
2012-02-11 23:56 Zac Medico
2012-02-11 21:41 Zac Medico
2012-02-11 21:11 Zac Medico
2012-02-11 19:35 Zac Medico
2012-02-11 2:59 Zac Medico
2012-02-10 0:42 Zac Medico
2012-02-10 0:20 Zac Medico
2012-02-10 0:17 Zac Medico
2012-02-09 7:25 Zac Medico
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=1523868381.1ee8971ba1cb34e6b3cd3d5fda23066b24630e3a.zmedico@gentoo \
--to=zmedico@gentoo.org \
--cc=gentoo-commits@lists.gentoo.org \
--cc=gentoo-dev@lists.gentoo.org \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox