mapserver/server/tilerendererjob/job.go

package tilerendererjob

import (
	"mapserver/app"
	"mapserver/coords"
)

func Job(ctx *app.App) {

	rstate := ctx.Config.RenderState
	jobs := make(chan *coords.TileCoords, ctx.Config.RenderingQueue)

	for i := 0; i < ctx.Config.RenderingJobs; i++ {
		go worker(ctx, jobs)
	}

	if rstate.InitialRun {
		initialRender(ctx, jobs)
	}

	incrementalRender(ctx, jobs)

	panic("render job interrupted!")

}