MCPcopy Index your code
hub / github.com/python/cpython / asyncqueue

Method asyncqueue

Lib/idlelib/rpc.py:236–244  ·  view source on GitHub ↗
(self, oid, methodname, args, kwargs)

Source from the content-addressed store, hash-verified

234 return seq
235
236 def asyncqueue(self, oid, methodname, args, kwargs):
237 request = ("QUEUE", (oid, methodname, args, kwargs))
238 seq = self.newseq()
239 if threading.current_thread() != self.sockthread:
240 cvar = threading.Condition()
241 self.cvars[seq] = cvar
242 self.debug(("asyncqueue:%d:" % seq), oid, methodname, args, kwargs)
243 self.putmessage((seq, request))
244 return seq
245
246 def asyncreturn(self, seq):
247 self.debug("asyncreturn:%d:call getresponse(): " % seq)

Callers 3

remotequeueMethod · 0.95
runcodeMethod · 0.80
runMethod · 0.80

Calls 4

newseqMethod · 0.95
debugMethod · 0.95
putmessageMethod · 0.95
ConditionMethod · 0.45

Tested by

no test coverage detected