Вызов функции в канале Голанг

Question

Я пытался заставить функцию вызываться «внутри» канала Голанга (например, pythons pool.apply_async, где я могу поставить в очередь загрузку функций и запустить их одновременно позже).Но безрезультатно.Все, что я прочитал, наводит меня на мысль, что это возможно, но теперь я думаю, что это не так, поскольку я вижу ошибку компиляции за ошибкой для всего, что я пытаюсь.Код ниже (должен быть автономным и работоспособным)

package main

import (
    "fmt"
    "math"
)

type NodeSettings struct {
    Timeout  int
    PanelInt float64
    PanelCCT float64
    SpotInt  float64
    SpotCCT  float64
    FadeTime int
    Port     int
}

func main() {
    fmt.Println("Attempting comms with nodes")

    futures := make(chan func(ip string, intLevel, cctLevel int, ns *NodeSettings), 100)
    results := make(chan int, 100)

    ns := NodeSettings{
        Timeout:  5,
        PanelInt: 58.0,
        PanelCCT: 6800.0,
        SpotInt:  60.0,
        SpotCCT:  2000.0,
        FadeTime: 0,
        Port:     40056,
    }

    spots := []string{"192.168.52.62", ...snipped}

    panels := []string{"192.168.52.39", ...snipped}

    for _, ip := range panels {
        intLevel := math.Round(254.0 / 100.0 * ns.PanelInt)
        cctLevel := math.Round((7300.0 - ns.PanelCCT) / (7300.0 - 2800.0) * 254.0)
        fmt.Printf("IP %s was set to %d (=%d%%) and %d (=%d K)\n",
            ip, int(intLevel), int(ns.PanelInt), int(cctLevel), int(ns.PanelCCT))
        futures <- set6Sim(ip, int(intLevel), int(cctLevel), &ns)
    }

    for _, ip := range spots {
        intLevel := math.Round(254.0 / 100.0 * ns.SpotInt)
        cctLevel := math.Round((6500.0 - ns.SpotCCT) / (6500.0 - 1800.0) * 254.0)
        fmt.Printf("IP %s was set to %d (=%d%%) and %d (=%d K)\n",
            ip, int(intLevel), int(ns.SpotInt), int(cctLevel), int(ns.SpotCCT))
        futures <- set8Sim(ip, int(intLevel), int(cctLevel), &ns)
    }
    close(futures)

    fmt.Println("Complete")
}

func set6Sim(ip string, intLevel, cctLevel int, ns *NodeSettings) int {
    fmt.Println(fmt.Sprintf("Simulated (6) run for IP %s", ip))
    return 1
}

func set8Sim(ip string, intLevel, cctLevel int, ns *NodeSettings) int {
    fmt.Println(fmt.Sprintf("Simulated (8) run for IP %s", ip))
    return 1
}

Первоначально мое определение чана было make(chan func(), 100), что привело к:

.\nodesWriteTest.go:52:11: cannot use set6Sim(ip, int(intLevel), int(cctLevel), &ns) (type int) as type func() in send
.\nodesWriteTest.go:60:11: cannot use set8Sim(ip, int(intLevel), int(cctLevel), &ns) (type int) as type func() in send

Что, как я предполагал, было связано сподпись не совпадает, но, увы, даже с совпадающими сигнатурами я все еще получаю похожую ошибку:

.\nodesWriteTest.go:51:11: cannot use set6Sim(ip, int(intLevel), int(cctLevel), &ns) (type int) as type func(string, int, int, *NodeSettings) in send
.\nodesWriteTest.go:59:11: cannot use set8Sim(ip, int(intLevel), int(cctLevel), &ns) (type int) as type func(string, int, int, *NodeSettings) in send

Начинаю думать, что это невозможно, так есть ли другой способ добиться того же?Или я просто не совсем понял это правильно.Спасибо.

Answer 1

Итак, вы пытаетесь отправить int вместо анонимной функции func(), поскольку ваши операторы set6Sim и set8Sim оба возвращают int с.Вот почему компилятор выдает вам эту ошибку.

Вместо этого вам необходимо структурировать анонимную функцию для отправки в канал, например:

    futures <- func(ip string, intLevel, cctLevel int, ns *NodeSettings) {
        set6Sim(ip, int(intLevel), int(cctLevel), ns)
    }

Ваш коднемного трудно следовать, так как мы понятия не имеем, что вы пытаетесь сделать.Так что без минимального примера это, мы надеемся, укажет вам правильное направление с тем, что вы пытаетесь решить.