האזנה לערוץ בתוך כמה פונקציות במקביל

[יוסף בן שמעון]

@nigun סורי, לא הצלחתי להבין איך נכנסו הערוצים לתמונה, למה לא לעשות כמו שעשו כל הדורות מימות אסמבלי ועד ימינו, כשמגיע השלב שאתה רוצה לדחוף פקודה למאזין, קרא לפונקציה חיצונית, תעביר לה פרמטרים נצרכים (user, data) ותקבל את הערך המוחזר. (אולי בגלל שאני לא מכיר אסטריסק)

[nigun]

@יוסף-בן-שמעון
פשוט אין שלב שבו אני רוצה לקרוא למאזין
אני תמיד רוצה להשאיר את האופציה לקריאה פתוחה
למשל אם המאזין הרגע התחיל להקשיב לקובץ באורך של שעה, ואני רוצה להעיף אותו משם ,שיקשיב למשהו אחר
אני פשוט בונה את כל הפקודות בצורה אסינכרונית , דהיינו שמפעיל את הפקודה "השמע קובץ פלוני" אבל עם go לפני הפקודה
ומיד אחר כך ממשיך להמתין לפקודות שלי
ככה זה נראה בערך בקוד

 for {
                     	msg := <-c
                        msgsplit := strings.Split(mesege, ":")
                        if msgsplit[0] == user {

                                filename := msgsplit[1]
                           
                                go myAgi.StreamFile(filename, "")
                              

                        }

בקוד הנ"ל המאזין מקבל את הערך מהערוץ בודק האם זה תואם את השם שלו
אם כן , הוא בודק מה הערך השני שנשלח (אחרי הנקודותיים)
ומשמיע את הקובתץ למאזין ומיד אחרי הפקודה להשמיע את הקובץ הוא חוזר להאזין.

[יוסף בן שמעון]

@nigun מה דעתך על שימוש במפה, שהמפתחות שלה הם המזהים של המשתמשים, נראה לי יותר קריא ונקי
כל משתמש שמתחבר אתה מקים לו ערוץ, וכשהוא יתנתק אתה דואג לנתק אותו כדי לשחרר את הערוץ ולעצור את ההאזנה האינסופית

package main

import (
	"fmt"
	"time"
)

var usersChannels = make(map[string]chan string)

func main() {
	go helloUser("A")
	go helloUser("B")
	time.Sleep(500)
	sendDataToUser("A", "Hi")
	sendDataToUser("B", "By")
	time.Sleep(500)
	disconnectUser("A")
	sendDataToUser("A", "Hi")
	time.Sleep(5000)
}

func helloUser(name string) {
	usersChannels[name] = make(chan string) // כאן אתה מוסיף את הערוץ של המשתמש למפה
	for {
		msg, isConnected := <-usersChannels[name] // מאזין למידע מהערוץ
		if !isConnected { // אם המידע הוא שהערוץ נסגר, זה אומר שהמשתמש התנתק ואפשר לעצור את הפונקציה
			return
		}
		fmt.Println(msg)
	}
}

func disconnectUser(name string) { // סוגר את הערוץ כדי לעצור את ההאזנה ומוחק את המשתמש מהמפה
	close(usersChannels[name])
	delete(usersChannels, name)
}

func sendDataToUser(name, data string) {
	channel, hasUser := usersChannels[name]
	if hasUser { // כדי למנוע מצב שהמשתמש כבר התנתק והערוץ שלו לא קיים במפה
		channel <- data
	}
}

[יוסף בן שמעון]

@nigun אליבא דאמת שימוש בערוצים במקרה הזה סתם מכביד על הקוד, קח מוטציה קלילה יותר של זה, במקום ערוצים שמתי קולבקים

package main

import (
	"fmt"
	"time"
)

var usersCallback = make(map[string]func(data string))

func main() {
	go helloUser("A")
	go helloUser("B")
	time.Sleep(500)
	sendDataToUser("A", "Hi")
	sendDataToUser("B", "By")
	time.Sleep(500)
	disconnectUser("A")
	sendDataToUser("A", "Hi")
	time.Sleep(5000)
}

func helloUser(name string) {
	usersCallback[name] = func(msg string) {
		fmt.Println(msg)
	}
}

func disconnectUser(name string) {
	delete(usersCallback, name)
}

func sendDataToUser(name, data string) {
	callback, hasUser := usersCallback[name]
	if hasUser {
		callback(data)
	}
}

[nigun]

@יוסף-בן-שמעון
את האמת אני לא מכיר בכלל את הקונספט של קולבקים
כנראה אני אשב על זה מתי שהוא ללמוד את זה (לא נראה מסובך)