1 =>
runtime: gp: gp=0xc00041e820, goid=347, gp->atomicstatus=1
runtime:  g:  g=0x1392220, goid=0,  g->atomicstatus=0
fatal error: bad g->status in ready

2 =>
fatal error: casgstatus: waiting for Gwaiting but is Grunnable

fatal error: unexpected signal during runtime execution
[signal SIGSEGV: segmentation violation code=0x1 addr=0x330 pc=0x1038847]

package itogami_test

import (
	"github.com/alphadose/itogami"
	"runtime/debug"
	"sync"
	"testing"
)

func doing() {
	times := 1000
	size := 100
	task := func(i int) {
		_ = i + 1
	}

	pool := itogami.NewPoolWithFunc(uint64(size), task)

	var wg sync.WaitGroup
	wg.Add(size)

	for i := 0; i < size; i++ {
		go func() {
			for n := 0; n < times; n++ {
				pool.Invoke(n)
			}
			wg.Done()
		}()
	}
	wg.Wait()
}

func TestTriggerGC(t *testing.T) {
	debug.SetMemoryLimit((1 << 20) * 100) // 100m

	for i := 0; i < 100; i++ {
		doing()
	}
}

func (b *Bubble) Init() tea.Cmd {
	go func() {
		pool := itogami.NewPoolWithFunc(uint64(b.Data.Thread), func(i uint32) {
			b.mainScrapInit(b.Data.Weblist[i])
			defer b.wg.Done()
		})

		for i := uint32(0); i < uint32(len(b.Data.Weblist)); i++ {
			b.wg.Add(1)
			pool.Invoke(i)
		}
		b.wg.Wait()
		close(channelMsg)
	}()
	return tea.Batch(doneTick(), func() tea.Msg { return Channel{<-channelMsg, channelMsg} })
}