日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程语言 > python >内容正文

python

python asyncio future_Python asyncio.isfuture方法代码示例

發布時間:2023/12/3 python 22 豆豆
生活随笔 收集整理的這篇文章主要介紹了 python asyncio future_Python asyncio.isfuture方法代码示例 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

本文整理匯總了Python中asyncio.isfuture方法的典型用法代碼示例。如果您正苦于以下問題:Python asyncio.isfuture方法的具體用法?Python asyncio.isfuture怎么用?Python asyncio.isfuture使用的例子?那么恭喜您, 這里精選的方法代碼示例或許可以為您提供幫助。您也可以進一步了解該方法所在模塊asyncio的用法示例。

在下文中一共展示了asyncio.isfuture方法的10個代碼示例,這些例子默認根據受歡迎程度排序。您可以為喜歡或者感覺有用的代碼點贊,您的評價將有助于我們的系統推薦出更棒的Python代碼示例。

示例1: test_isfuture

?點贊 6

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def test_isfuture(self):

class MyFuture:

_asyncio_future_blocking = None

def __init__(self):

self._asyncio_future_blocking = False

self.assertFalse(asyncio.isfuture(MyFuture))

self.assertTrue(asyncio.isfuture(MyFuture()))

self.assertFalse(asyncio.isfuture(1))

self.assertFalse(asyncio.isfuture(asyncio.Future))

# As `isinstance(Mock(), Future)` returns `False`

self.assertFalse(asyncio.isfuture(mock.Mock()))

# As `isinstance(Mock(Future), Future)` returns `True`

self.assertTrue(asyncio.isfuture(mock.Mock(asyncio.Future)))

f = asyncio.Future(loop=self.loop)

self.assertTrue(asyncio.isfuture(f))

f.cancel()

開發者ID:ShikyoKira,項目名稱:Project-New-Reign---Nemesis-Main,代碼行數:24,

示例2: test_isfuture

?點贊 6

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def test_isfuture(self):

class MyFuture:

_asyncio_future_blocking = None

def __init__(self):

self._asyncio_future_blocking = False

self.assertFalse(asyncio.isfuture(MyFuture))

self.assertTrue(asyncio.isfuture(MyFuture()))

self.assertFalse(asyncio.isfuture(1))

# As `isinstance(Mock(), Future)` returns `False`

self.assertFalse(asyncio.isfuture(mock.Mock()))

f = self._new_future(loop=self.loop)

self.assertTrue(asyncio.isfuture(f))

self.assertFalse(asyncio.isfuture(type(f)))

# As `isinstance(Mock(Future), Future)` returns `True`

self.assertTrue(asyncio.isfuture(mock.Mock(type(f))))

f.cancel()

開發者ID:bkerler,項目名稱:android_universal,代碼行數:24,

示例3: test_api_calls_return_a_response_when_run_in_sync_mode

?點贊 5

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def test_api_calls_return_a_response_when_run_in_sync_mode(self):

self.client.token = "xoxb-api_test"

resp = self.client.api_test()

self.assertFalse(asyncio.isfuture(resp))

self.assertTrue(resp["ok"])

開發者ID:slackapi,項目名稱:python-slackclient,代碼行數:7,

示例4: test_api_calls_return_a_future_when_run_in_async_mode

?點贊 5

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def test_api_calls_return_a_future_when_run_in_async_mode(self):

self.client.token = "xoxb-api_test"

self.client.run_async = True

future = self.client.api_test()

self.assertTrue(asyncio.isfuture(future))

resp = await future

self.assertEqual(200, resp.status_code)

self.assertTrue(resp["ok"])

開發者ID:slackapi,項目名稱:python-slackclient,代碼行數:10,

示例5: _dispatch

?點贊 5

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def _dispatch(self, f, value=None):

self._check_exhausted()

if f is None:

return

elif asyncio.isfuture(f):

f.set_result(value)

elif asyncio.iscoroutinefunction(f):

self.loop.create_task(f(value))

else:

f(value)

# self.loop.call_soon(functools.partial(f, value))

開發者ID:zh217,項目名稱:aiochan,代碼行數:14,

示例6: __init__

?點贊 5

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def __init__(self, identifier, hashable_key, type_spec, target_future):

"""Creates a cached value.

Args:

identifier: An instance of `CachedValueIdentifier`.

hashable_key: A hashable source value key, if any, or `None` of not

applicable in this context, for use during cleanup.

type_spec: The type signature of the target, an instance of `tff.Type`.

target_future: An asyncio future that returns an instance of

`executor_value_base.ExecutorValue` that represents a value embedded in

the target executor.

Raises:

TypeError: If the arguments are of the wrong types.

"""

py_typecheck.check_type(identifier, CachedValueIdentifier)

py_typecheck.check_type(hashable_key, collections.Hashable)

py_typecheck.check_type(type_spec, computation_types.Type)

if not asyncio.isfuture(target_future):

raise TypeError('Expected an asyncio future, got {}'.format(

py_typecheck.type_string(type(target_future))))

self._identifier = identifier

self._hashable_key = hashable_key

self._type_spec = type_spec

self._target_future = target_future

self._computed_result = None

開發者ID:tensorflow,項目名稱:federated,代碼行數:28,

示例7: test_mock_from_create_future

?點贊 5

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def test_mock_from_create_future(self, klass):

loop = asyncio.new_event_loop()

try:

if not (hasattr(loop, "create_future") and

hasattr(asyncio, "isfuture")):

return

mock = klass(loop.create_future())

self.assertTrue(asyncio.isfuture(mock))

finally:

loop.close()

開發者ID:Martiusweb,項目名稱:asynctest,代碼行數:14,

示例8: isfuture

?點贊 5

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def isfuture(fut):

return isinstance(fut, asyncio.Future)

開發者ID:skylander86,項目名稱:lambda-text-extractor,代碼行數:4,

示例9: test_start_stop

?點贊 5

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def test_start_stop(self):

self.assertTrue(asyncio.isfuture(self.order_book_tracker._order_book_snapshot_router_task))

self.order_book_tracker.stop()

self.assertIsNone(self.order_book_tracker._order_book_snapshot_router_task)

self.order_book_tracker.start()

開發者ID:CoinAlpha,項目名稱:hummingbot,代碼行數:7,

示例10: test_wrap_future

?點贊 5

?

# 需要導入模塊: import asyncio [as 別名]

# 或者: from asyncio import isfuture [as 別名]

def test_wrap_future(self):

def run(arg):

return (arg, threading.get_ident())

ex = concurrent.futures.ThreadPoolExecutor(1)

f1 = ex.submit(run, 'oi')

f2 = asyncio.wrap_future(f1, loop=self.loop)

res, ident = self.loop.run_until_complete(f2)

self.assertTrue(asyncio.isfuture(f2))

self.assertEqual(res, 'oi')

self.assertNotEqual(ident, threading.get_ident())

ex.shutdown(wait=True)

開發者ID:bkerler,項目名稱:android_universal,代碼行數:14,

注:本文中的asyncio.isfuture方法示例整理自Github/MSDocs等源碼及文檔管理平臺,相關代碼片段篩選自各路編程大神貢獻的開源項目,源碼版權歸原作者所有,傳播和使用請參考對應項目的License;未經允許,請勿轉載。

總結

以上是生活随笔為你收集整理的python asyncio future_Python asyncio.isfuture方法代码示例的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。