Skip to content

Threaded dispatcher loop #23

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 16 commits into from
Closed

Threaded dispatcher loop #23

Changes from 1 commit
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
9ff7372
Threaded dispatcher loop
Archmonger Oct 27, 2021
65ccaa6
Revert "Threaded dispatcher loop"
Archmonger Oct 27, 2021
2cf8e20
threading asyncio run
Archmonger Oct 27, 2021
698e4ed
working implementation (thread-safe queue
Archmonger Oct 28, 2021
2ee570e
close out thread before disconnect
Archmonger Oct 28, 2021
b8a59d8
do not block on Thread.join()
Archmonger Oct 28, 2021
0cc0915
remove useless super
Archmonger Oct 28, 2021
94d1892
add daemon as constructor arg
Archmonger Oct 28, 2021
13989c6
close thread via exception
Archmonger Oct 30, 2021
3db5aa4
mvoe recv_queue back to dispatch loop
Archmonger Oct 30, 2021
03ee090
unbork exception logic
Archmonger Oct 30, 2021
a35c671
Merge remote-tracking branch 'upstream/main' into threaded-dispatcher…
Archmonger Dec 22, 2021
8660301
reset websocket consumer to main
Archmonger Dec 22, 2021
fb229da
var cleanup
Archmonger Dec 22, 2021
d0d2e99
new implementation
Archmonger Dec 22, 2021
cee6174
remove janus
Archmonger Dec 22, 2021
File filter

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
remove useless super
  • Loading branch information
@Archmonger
Archmonger committed Oct 28, 2021
commit 0cc0915e26fd2f24841084608621c51e76148d83
1 change: 0 additions & 1 deletion src/django_idom/websocket_consumer.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,6 @@ async def connect(self) -> None:
self._idom_dispatcher_thread.start()

async def disconnect(self, code: int) -> None:
await super().disconnect(code)
self._idom_dispatcher_thread.join(timeout=0)

async def receive_json(self, content: Any, **kwargs: Any) -> None:
Expand Down