当前位置：首页 > news >正文

go语言中空结构体

news 来源：原创 2025/4/30 7:20:35

在这里插入图片描述

空结构体(struct{})

普通理解

在结构体中，可以包裹一系列与对象相关的属性，但若该对象没有属性呢？那它就是一个空结构体。

空结构体，和正常的结构体一样，可以接收方法函数。

type Lamp struct{}

func (l Lamp) On() {
        println("On")

}
func (l Lamp) Off() {
        println("Off")
}

空结构体的妙用

空结构体的表象特征，就是没有任何属性，而从更深层次的角度来说，空结构体是一个不占用空间的对象。

使用 unsafe.Sizeof 可以轻易的验证这个结果

type Lamp struct{}

func main() {
    lamp := Lamp{}
    fmt.Print(unsafe.Sizeof(lamp))
}
// output: 0

基于这个特性，在一些特殊的场合之下，可以用做占位符使用，合理的使用空结构体，会减小程序的内存占用空间。

比如在使用信道(channel)控制并发时，我们只是需要一个信号，但并不需要传递值，这个时候，也可以使用 struct{} 代替。

func main() {
    ch := make(chan struct{}, 1)
    go func() {
        <-ch
        // do something
    }()
    ch <- struct{}{}
    // ...
}

在 Go 语言中，使用空结构体（struct{}）作为通道（chan）的元素类型是一种常见的优化手段。这种做法主要出于以下几个原因：

节省内存
空结构体 struct{} 在 Go 中不占用任何内存空间（大小为 0 字节）。因此，当你需要一个通道来传递信号或同步协程时，使用空结构体可以避免不必要的内存开销。
信号传递
在某些场景下，你并不需要通过通道传递具体的数据，而只是需要一个简单的信号机制来通知其他协程某个事件已经发生。例如，用于关闭多个工作协程、通知某个操作完成等。此时，空结构体作为通道的元素类型非常合适。
提高性能
由于空结构体不占用内存，发送和接收空结构体的操作通常比发送和接收复杂数据类型的通道更快。虽然这种差异在大多数情况下是微不足道的，但在高并发或高性能要求的场景下，这些细微的优化可能会产生显著的影响。

.关闭多个工作协程

package main

import (
    "fmt"
    "time"
)

func worker(id int, done chan struct{}) {
    for {
        select {
        case <-done:
            fmt.Printf("Worker %d shutting down\n", id)
            return
        default:
            fmt.Printf("Worker %d working\n", id)
            time.Sleep(500 * time.Millisecond)
        }
    }
}

func main() {
    done := make(chan struct{})
    numWorkers := 3

    // 启动多个工作协程
    for i := 1; i <= numWorkers; i++ {
        go worker(i, done)
    }

    // 模拟一些工作
    time.Sleep(2 * time.Second)

    // 发送关闭信号
    close(done)

    // 等待一段时间以确保所有工作协程都已退出
    time.Sleep(1 * time.Second)
}

在这个例子中，done 通道被用来通知所有工作协程停止工作。我们不需要通过通道传递任何实际的数据，只需要一个信号即可。

.同步操作完成

package main

import (
    "fmt"
    "sync"
)

func task(id int, wg *sync.WaitGroup, done chan struct{}) {
    defer wg.Done()
    fmt.Printf("Task %d completed\n", id)
    done <- struct{}{} // 发送一个空结构体表示任务完成
}

func main() {
    var wg sync.WaitGroup
    done := make(chan struct{}, 3) // 缓冲区大小为任务数量

    for i := 1; i <= 3; i++ {
        wg.Add(1)
        go task(i, &wg, done)
    }

    // 等待所有任务完成
    go func() {
        wg.Wait()
        close(done)
    }()

    // 接收所有完成信号
    for range done {
        fmt.Println("Received completion signal")
    }

    fmt.Println("All tasks completed")
}