thread.go

package gost

import (
	"fmt"
	"time"
)

// Puts the current thread to sleep for at least the specified amount of time.
//
//	gost.Sleep(gost.DurationFromSecs(5)) // Sleep for 5 seconds
func Sleep(dur Duration) {
	durationString := fmt.Sprintf("%ds%dns", dur.seconds, dur.nanoseconds)

	duration, err := time.ParseDuration(durationString)

	if err != nil {
		panic(err)
	}

	time.Sleep(duration)
}

// An owned permission to join on a thread (block on its termination).
type JoinHandle struct {
	channel chan Unit
}

// Waits for the associated thread to finish.
func (self JoinHandle) Join() Result[Unit] {
	<-self.channel

	return Ok(Unit{})
}

// Checks if the associated thread has finished running its main function.
func (self JoinHandle) IsFinished() bool {
	select {
	case <-self.channel:
		return true
	default:
		return false
	}
}

// Spawns a new thread, returning a JoinHandle for it.
func Spawn(f func()) JoinHandle {
	channel := make(chan Unit)

	go func() {
		f()
		channel <- Unit{}
	}()

	return JoinHandle{
		channel,
	}
}