University-of-Basel-Studentprojects/Programmierprojekt
Archived
1
0
Fork 0
Code Issues 17 Pull Requests Actions Wiki Activity

Add SessionReader and SessionWriter worker threads for session #198

Merged
lars.winzer merged 20 commits from feat/session-reader-and-writer-thread into main 2026-03-20 17:39:44 +01:00
Conversation 2 Commits 20 Files Changed 8
+10 -9
1 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 94fcd88223 - Show all commits
src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/SessionManager.java
+10 -9
View File
@@ -32,18 +32,19 @@ public class SessionManager {
*/ */
public Session create(TransportLayer transport) { public Session create(TransportLayer transport) {
Session session = new Session(transport, eventBus); Session session = new Session(transport, eventBus);
SessionReader reader = new SessionReader(session, eventBus); SessionReader reader = new SessionReader(session, eventBus);
Thread readerThread = new Thread(reader, "session-" + session.getId().value() + "-reader");
readerThread.start();
SessionWriter writer = new SessionWriter(session); SessionWriter writer = new SessionWriter(session);
Thread writerThread = new Thread(writer, "session-" + session.getId().value() + "-writer");
writerThread.start();
SessionHandle handle = new SessionHandle(session, readerThread, writerThread); Thread readerThread = Thread.ofVirtual()
sessions.put(session.getId(), handle); .name("session-" + session.getId().value() + "-reader")
logger.debug("Created new session {}", session.getId().value()); .unstarted(reader);
Thread writerThread = Thread.ofVirtual()
.name("session-" + session.getId().value() + "-writer")
.unstarted(writer);
sessions.put(session.getId(), new SessionHandle(session, readerThread, writerThread));
readerThread.start();
writerThread.start();
return session; return session;
} }