main.go

package main

import (
	"errors"
	"fmt"
	"runtime"
	"time"
	
	"github.com/linkerlin/GoExecutors/config"
	"github.com/linkerlin/GoExecutors/executors"
)

func main() {
	config.LoadConfig()
	fmt.Println("Default goroutines number is ", config.DefaultGoroutinesNum())
	es := executors.NewExecutors()
	f := func() (interface{}, error) {
		fmt.Println("这是从一个Callable内部发出的声音。")
		//		time.Sleep(time.Second * 1)
		return 1, nil
	}

	var future = es.Submit(f)
	var ret, t, e, ex = future.GetResult(time.Millisecond * 1500)
	switch {
	case ex != nil:
		fmt.Println("异常", ex)
	case t == nil && e == nil:
		fmt.Println("No.1 正常", ret)
	case t != nil:
		fmt.Println("超时！")
	case e != nil:
		fmt.Println("出错", e)
	default:
		fmt.Println("不会到这里", ret)
	}
	fTimeout := func() (interface{}, error) {
		time.Sleep(time.Second * 1)
		fmt.Println("这是第二次从Callable内部发出的声音。")
		return 2, errors.New("1s")
	}
	fmt.Println("=================")
	time.Sleep(100)
	future = es.Submit(fTimeout)
	ret2, t, err, ex := future.GetResult(time.Millisecond * 500)
	switch {
	case ex != nil:
		fmt.Println("异常", ex)
	case t == nil && err == nil:
		fmt.Println("执行成功", ret2)
	case err != nil:
		fmt.Println("执行出错", err)
	case t != nil:
		fmt.Println("No.2 超时！", t)
	default:
		fmt.Println("不会到这里", ret2)
	}
	fPanic := func() (interface{}, error) {
		fmt.Println("这是第三次从Callable内部发出的声音。")
		panic(100)
	}
	for i := 0; i < 3; i++ {
		future = es.Submit(fPanic)
	}

	ret3, t, err, ex := future.GetResult(time.Millisecond * 500)
	switch {
	case ex != nil:
		fmt.Printf("No.3 异常 %d\n", es.GetGoNum())
	case err == nil && t == nil:
		fmt.Println("执行失败,没有捕获到错误", ret3)
	case t != nil:
		fmt.Println("执行失败,超时", t)
	case err != nil:
		fmt.Println("执行成功,捕获到", err)
	default:
		fmt.Println("不会到这里", ret3)
	}

	f = func() (interface{}, error) {
		fmt.Println("这是从No.4 Callable内部发出的声音。", es.GetGoNum())
		//		time.Sleep(time.Second * 1)
		return 1, errors.New("😀")
	}

	future = es.Submit(f)
	ret, t, e, ex = future.GetResult(time.Millisecond * 1500)
	switch {
	case ex != nil:
		fmt.Println("异常", ex)
	case t == nil && e == nil:
		fmt.Println("正常", ret)
	case t != nil:
		fmt.Println("超时！")
	case e != nil:
		fmt.Println("No.4 出错", e)
	default:
		fmt.Println("不会到这里", ret)
	}
	fmt.Println("GoNum:", es.GetGoNum())
	time.Sleep(time.Second * 3)
	fmt.Println("GoNum:", es.GetGoNum())
	es.Stop()
	for es.GetGoNum() > 0 {
		runtime.Gosched()
		fmt.Println("GoNum:", es.GetGoNum())
		time.Sleep(time.Millisecond * 100)
	}
	fmt.Println("GoNum:", es.GetGoNum())
}