Home
last modified time | relevance | path

Searched refs:asyncio (Results 1 – 25 of 31) sorted by relevance

12

/AliOS-Things-master/components/py_engine/tests/extmod/
A Duasyncio_event.py4 import uasyncio as asyncio namespace
7 import asyncio
20 await asyncio.sleep(t)
26 ev = asyncio.Event()
40 await asyncio.sleep(0)
44 await asyncio.sleep(0)
50 await asyncio.sleep(0)
57 await asyncio.sleep(0)
64 ev = asyncio.Event()
73 ev = asyncio.Event()
[all …]
A Duasyncio_wait_for.py4 import uasyncio as asyncio namespace
7 import asyncio
15 await asyncio.sleep(t)
23 await asyncio.sleep(0.2)
24 except asyncio.CancelledError:
36 await asyncio.sleep(t)
102 await asyncio.sleep(0.01)
104 await asyncio.sleep(0.01)
109 await asyncio.sleep(0.01)
111 await asyncio.sleep(0.01)
[all …]
A Duasyncio_cancel_task.py4 import uasyncio as asyncio namespace
7 import asyncio
16 await asyncio.sleep(s)
41 await asyncio.sleep(0.01)
44 await asyncio.sleep(0.01)
48 await asyncio.sleep(0.01)
52 await asyncio.sleep(0.01)
63 await asyncio.sleep(0.05)
73 await asyncio.sleep(0.1)
82 await asyncio.sleep(0.1)
[all …]
A Duasyncio_lock.py4 import uasyncio as asyncio namespace
7 import asyncio
24 await asyncio.sleep(0.2)
44 lock = asyncio.Lock()
50 await asyncio.sleep(0)
53 await asyncio.sleep(0)
65 await asyncio.sleep(0)
72 await asyncio.sleep(0.1)
81 await asyncio.sleep(0.3)
91 await asyncio.sleep(0.1)
[all …]
A Duasyncio_wait_for_fwd.py4 import uasyncio as asyncio namespace
7 import asyncio
16 await asyncio.sleep(t)
17 except asyncio.CancelledError as er:
35 except asyncio.TimeoutError as er:
38 except asyncio.CancelledError as er:
45 await asyncio.sleep(0.01)
49 t = asyncio.create_task(wait())
50 k = asyncio.create_task(cancel(t))
53 except asyncio.CancelledError:
[all …]
A Duasyncio_lock_cancel.py4 import uasyncio as asyncio namespace
7 import asyncio
17 except asyncio.CancelledError:
22 await asyncio.sleep(0)
30 lock = asyncio.Lock()
35 t0 = asyncio.create_task(task(0, lock, lock_flag))
36 t1 = asyncio.create_task(task(1, lock, lock_flag))
37 t2 = asyncio.create_task(task(2, lock, lock_flag))
39 await asyncio.sleep(0)
49 await asyncio.sleep(0)
[all …]
A Duasyncio_set_exception_handler.py4 import uasyncio as asyncio namespace
7 import asyncio
23 loop = asyncio.get_event_loop()
33 asyncio.create_task(task(0))
36 await asyncio.sleep(0)
39 asyncio.create_task(task(1))
40 asyncio.create_task(task(2))
43 await asyncio.sleep(0)
46 t = asyncio.create_task(task(3))
47 await asyncio.sleep(0)
[all …]
A Duasyncio_task_done.py4 import uasyncio as asyncio namespace
7 import asyncio
16 await asyncio.sleep(t)
25 t = asyncio.create_task(task(-1))
27 await asyncio.sleep(0)
34 t = asyncio.create_task(task(0.01))
36 await asyncio.sleep(0)
43 t = asyncio.create_task(task(-1, ValueError))
45 await asyncio.sleep(0)
57 await asyncio.sleep(0)
[all …]
A Duasyncio_fair.py4 import uasyncio as asyncio namespace
7 import asyncio
18 await asyncio.sleep(t)
22 t1 = asyncio.create_task(task(1, -0.01))
23 t2 = asyncio.create_task(task(2, 0.1))
24 t3 = asyncio.create_task(task(3, 0.18))
25 t4 = asyncio.create_task(task(4, -100))
26 await asyncio.sleep(0.5)
34 asyncio.run(main())
A Duasyncio_event_fair.py5 import uasyncio as asyncio namespace
8 import asyncio
17 await asyncio.sleep(0)
29 ev = asyncio.Event()
31 asyncio.create_task(task1(0)),
32 asyncio.create_task(task2(2, ev)),
33 asyncio.create_task(task1(1)),
34 asyncio.create_task(task2(3, ev)),
40 asyncio.run(main())
A Duasyncio_wait_task.py4 import uasyncio as asyncio namespace
7 import asyncio
30 await asyncio.sleep(t)
43 t = asyncio.create_task(task(1))
47 t = asyncio.create_task(task(2))
48 await asyncio.sleep(0.001)
57 ts1 = asyncio.create_task(delay_print(0.04, "hello"))
58 ts2 = asyncio.create_task(delay_print(0.08, "world"))
70 t = asyncio.create_task(task_raise())
77 asyncio.run(main())
A Duasyncio_cancel_fair2.py5 import uasyncio as asyncio namespace
8 import asyncio
18 await asyncio.sleep(0)
19 except asyncio.CancelledError:
26 await asyncio.sleep(0)
31 t = asyncio.create_task(task_a())
33 asyncio.create_task(task_b(i, t))
37 asyncio.run(main())
A Duasyncio_cancel_fair.py5 import uasyncio as asyncio namespace
8 import asyncio
18 await asyncio.sleep(0)
20 except asyncio.CancelledError as er:
30 asyncio.create_task(task(0, 1)),
31 asyncio.create_task(task(1, 0)),
32 asyncio.create_task(task(2, None)),
37 asyncio.run(main())
A Duasyncio_heaplock.py16 import uasyncio as asyncio namespace
19 import asyncio
28 await asyncio.sleep_ms(t)
32 t1 = asyncio.create_task(task(1, 4, 10))
33 t2 = asyncio.create_task(task(2, 4, 25))
38 await asyncio.sleep_ms(1)
40 await asyncio.sleep_ms(100)
46 asyncio.run(main())
A Duasyncio_new_event_loop.py4 import uasyncio as asyncio namespace
7 import asyncio
16 await asyncio.sleep(0)
17 await asyncio.sleep(0)
23 await asyncio.sleep(0)
29 loop = asyncio.get_event_loop()
34 loop = asyncio.new_event_loop()
A Duasyncio_exception.py4 import uasyncio as asyncio namespace
7 import asyncio
20 asyncio.run(main())
33 t = asyncio.create_task(task())
39 asyncio.run(main())
52 asyncio.create_task(task())
58 asyncio.run(main())
A Duasyncio_gather.py4 import uasyncio as asyncio namespace
7 import asyncio
17 await asyncio.sleep(0.01)
25 await asyncio.sleep(0.2)
31 await asyncio.gather(task(1), task(2))
37 print(await asyncio.gather(factorial("A", 2), factorial("B", 3), factorial("C", 4)))
49 asyncio.run(main())
A Duasyncio_basic2.py2 import uasyncio as asyncio namespace
5 import asyncio
13 await asyncio.sleep(10)
18 asyncio.create_task(forever())
19 await asyncio.sleep(0.001)
24 print(asyncio.run(main()))
A Duasyncio_loop_stop.py4 import uasyncio as asyncio namespace
7 import asyncio
28 await asyncio.sleep(0)
32 asyncio.create_task(task())
33 await asyncio.sleep(0)
40 loop = asyncio.get_event_loop()
A Duasyncio_cancel_self.py4 import uasyncio as asyncio namespace
7 import asyncio
20 global_task = asyncio.create_task(task())
23 except asyncio.CancelledError:
29 asyncio.run(main())
/AliOS-Things-master/components/py_engine/tests/net_inet/
A Duasyncio_cancel_stream.py4 import uasyncio as asyncio namespace
7 import asyncio
18 except asyncio.CancelledError:
23 reader, writer = await asyncio.open_connection(url, 80)
24 task = asyncio.create_task(get(reader))
25 await asyncio.sleep(0)
35 asyncio.run(main("micropython.org"))
/AliOS-Things-master/components/py_engine/tests/multi_net/
A Duasyncio_tcp_readexactly.py4 import uasyncio as asyncio namespace
7 import asyncio
20 await asyncio.sleep(0.1)
41 ev = asyncio.Event()
42 server = await asyncio.start_server(handle_connection, "0.0.0.0", PORT)
46 await asyncio.wait_for(ev.wait(), 10)
50 reader, writer = await asyncio.open_connection(IP, PORT)
63 asyncio.run(tcp_server())
68 asyncio.run(tcp_client())
A Duasyncio_tcp_close_write.py4 import uasyncio as asyncio namespace
7 import asyncio
34 ev = asyncio.Event()
35 server = await asyncio.start_server(handle_connection, "0.0.0.0", PORT)
39 await asyncio.wait_for(ev.wait(), 5)
43 reader, writer = await asyncio.open_connection(IP, PORT)
64 asyncio.run(tcp_server())
69 asyncio.run(tcp_client())
A Duasyncio_tcp_server_client.py4 import uasyncio as asyncio namespace
7 import asyncio
34 ev = asyncio.Event()
35 server = await asyncio.start_server(handle_connection, "0.0.0.0", PORT)
39 await asyncio.wait_for(ev.wait(), 10)
43 reader, writer = await asyncio.open_connection(IP, PORT)
53 asyncio.run(tcp_server())
58 asyncio.run(tcp_client(b"client data"))
A Duasyncio_tcp_client_rst.py4 import uasyncio as asyncio namespace
7 import asyncio
20 await asyncio.sleep(0.2) # wait for client to drop connection
33 ev = asyncio.Event()
34 server = await asyncio.start_server(handle_connection, "0.0.0.0", PORT)
37 await asyncio.wait_for(ev.wait(), 10)
42 asyncio.run(main())

Completed in 22 milliseconds

12