golang channel 對比swoole chan 淺談

先談golang

package main

import (
    "fmt"
    "time"
)

//ex one 
func worker(id int, c chan int) {  
    for {
        fmt.Printf("is %d,come %c\n", id, <-c)
    }

}

//ex two return is a chan 
func createworker(id int) chan int {
    c := make(chan int)
    go func() {
        for {
            fmt.Printf("is %d,come %c\n", id, <-c)
        }
    }()
    return c
}

func chanDemo() {
    var channels [10]chan int
    //ex one
    for i := 0; i < 10; i++ {
        channels[i] = make(chan int)
        go worker(i, channels[i])
        channels[i] <- 'a' + i
        channels[i] <- 'A' + i
    }
    //extwo
    for i := 0; i < 10; i++ {
        channels[i] = createworker(i)
    }
    for i := 0; i < 10; i++ {
        channels[i] <- 'a' + i
    }
    for i := 0; i < 10; i++ {
        channels[i] <- 'B' + i
    }
    for i := 0; i < 10; i++ {
        channels[i] <- 'A' + i
    }
//like swoole co::sleep()
    time.Sleep(time.Microsecond)

}
func workerTwo(id int, c chan string) {
      //use your channal stop output
    for n := range c {

        fmt.Printf("is %d,come %s\n", id, n)
    }
}
//like swoole chan(3)
func bufferChannel() {
    c := make(chan string, 3)
    go workerTwo(0, c)
// input your channel
    c <- "蘋果皮"
    c <- "豆腐皮"
    c <- "香蕉皮"
    close(c)
//  like swoole co::sleep() 
    time.Sleep(time.Microsecond)
}

func main() {
    chanDemo()
    bufferChannel()
}

再看swoole

/**
 * 創(chuàng)建一個主協(xié)程
 */
const NUM = 1; //總執(zhí)行次數(shù)
$c = new chan(600); //定義管道
// 記錄開始時間
$StartTime = time();
const MaxCoroutine = 10; //默認3000
Swoole\Coroutine::set(array(
    'max_coroutine' => MaxCoroutine,
));
go(function () use ($c) {
    /**
     * 連接數(shù)據(jù)庫
     */
    $swoole_mysql = new Swoole\Coroutine\MySQL();
    $res = $swoole_mysql->connect([
        'host' => '127.0.0.1',
        'port' => 3306,
        'user' => 'root',
        'password' => 'root',
        'database' => 'demo',
        'fetch_mode' => true, //fetch 要開啟這個
    ]);

    if ($res == false) {
        //  log($res);
        echo "MYSQL-CONNECT-ERROR" . PHP_EOL;
        return;
    }
    /**
     * 調(diào)用pop防止 堵塞 子協(xié)程
     */
    go(function () use ($c, $swoole_mysql) {
        popChan($c, $swoole_mysql);
    });
    /**
     * 調(diào)用push  子協(xié)程 
     */
    go(function () use ($c) {
        pushChan($c);
    });
});

/**
 * 調(diào)用pop
 *
 * @param [type] $c
 * @param [type] $swoole_mysql
 * @return void
 */
function popChan(&$c, &$swoole_mysql)
{
    $n = 0;
    $stm = $swoole_mysql->prepare('insert into `cate` (`id`,`name`) value(?,?)');

    if (false == $stm) {
        // log("預(yù)處理錯誤的原因:" . $swoole_mysql->erron . ":" . $swoole_mysql->error);
        consolelog("mysql 添加失敗" . $swoole_mysql->error);
        die();
    }

    while (true) {
        consolelog("wite-begin-insert:" . date('Y-m-d H:i:s') . ":" . $n);
        //consolelog("insert-data:".json_encode($c->pop()));
        $n++;
        consolelog("begin-insert:" . date('Y-m-d H:i:s') . ":" . $n);
        $ret = $stm->execute([null, json_encode($c->pop())]);
        if (false == $ret) {
            //  log("添加錯誤的原因:" . $swoole_mysql->erron . ":" . $swoole_mysql->error);
            //consolelog('insert-error'. $swoole_mysql->erron() . ":" . $swoole_mysql->error());
            $n--; //回退
            $c->push($c->pop());
        }
        if (NUM == $n) {
            consolelog('End at : ' . date('Y-m-d H:i:s') . PHP_EOL
                . ' 耗時： ' . (time() - $GLOBALS['StartTime'])
                . 'S 速率： ' . round($n / (time() - $GLOBALS['StartTime']), 2) . '/S');
            return;
        }
    }
}
/**
 * push
 */
function pushChan(&$c)
{

    for ($i = 0; $i < NUM; $i++) {
        /**
         * 以防萬一
         */
        while ($c->isFull() || (Swoole\Coroutine::stats())['coroutine_num'] > MaxCoroutine - 5) {
            consolelog("sleep:" . $i);
            co::sleep(0.3);
        }

        $data = [
            'www.baidu.com',
            'www.qq.com',
            'www.csdn.com',
        ];
        foreach ($data as $v) {
            $ips[] = co::gethostbyname($v, AF_INET, 0.5);
            consolelog("begin-select:" . $i);
        }
        $c->push($ips);
    }
}


/**
 * 定義打印輸出
 *
 * @param [type] $msg
 * @return void
 */
function consolelog($msg)
{
    $msg = $msg . PHP_EOL;
    echo $msg;
}
/**
 * 定義日志文件
 *
 * @param [type] $msg
 * @return void
 */

因為協(xié)程是并行執(zhí)行的他的速度非沉镒澹快躬它，如果不用time我們看不到他的執(zhí)行結(jié)果,所以現(xiàn)在修改一下代碼,也可以實現(xiàn)

package main

import (
    "fmt"
)

//create worker
func createWorker(id int) workers {
    w := workers{
        in: make(chan int),
        done: make(chan bool),
    }
    go doWorker(id, w.in, w.done)
    return w
}

// do worker
func doWorker(id int, c chan int, done chan bool) {

    for n := range c {

        fmt.Printf("is %d,come %c\n", id, n)
        done <- true //out
    }
}

type workers struct { //type a struct
    in   chan int //in channel
    done chan bool //out channel
}

func chanDemo() {
    var workers [10]workers
    //extwo
    for i := 0; i < 10; i++ {
        workers[i] = createWorker(i)
    }
    //all words goto channel
    for i, worker := range workers {
        worker.in <- 'a' + i

    }
//make word out
    for _, woker := range workers {
        <-woker.done
    } 
//all words goto channel
    for i, worker := range workers {
        worker.in <- 'A' + i

    }
//make word out
    for _, woker := range workers {
        <-woker.done
    }
    

}

func main() {
    chanDemo()

}

golang里面內(nèi)置了一個WaitGroup方法 還可以這樣來

package main

import (
    "fmt"
    "sync"
)

//create worker
func createWorker(id int, wait *sync.WaitGroup) workers {
    w := workers{
        in:   make(chan int),
        wait: wait,
    }
    go doWorker(id, w.in, wait)
    return w
}

// do worker
func doWorker(id int, c chan int, wait *sync.WaitGroup) {

    for n := range c {

        fmt.Printf("is %d,come %c\n", id, n)
        wait.Done()

    }
}

type workers struct {
    in   chan int
    wait *sync.WaitGroup //usr chanDemo wait so use  *
}

func chanDemo() {
    var workers [10]workers
    var wait sync.WaitGroup

    for i := 0; i < 10; i++ {
        workers[i] = createWorker(i, &wait)
    }
    wait.Add(20) //we have 20 work todo
    for i, worker := range workers {
        worker.in <- 'a' + i
        //or we can do this
        //wait.Add(1)
    }
    for i, worker := range workers {
        worker.in <- 'A' + i
    }
    wait.Wait() //wait 20 work to end
}

func main() {
    chanDemo()

}

總結(jié):swoole的chan 類似于 隊列汇跨，先進先出,可以設(shè)置一個緩存區(qū),就是你的管道的長度, 在swoole里面有isFull方法進行判斷,如果滿了，可以將當前協(xié)程掛起伍俘，（其他判斷方法也可以）叽掘，如果發(fā)生I/O阻塞，協(xié)程本身就是并發(fā),大家可以想想會發(fā)生什么,你的CPU，內(nèi)存缀旁，所以代碼一定要嚴謹记劈。

go里面的channel是并行執(zhí)行,因為速度非常快,我們第一種通過time的方式可以實現(xiàn)輸出,第二種先并行執(zhí)行前10個并巍，done出來,再并行執(zhí)行后10個目木，done出來,第三種,通過內(nèi)置的waitgroup方法,并行執(zhí)行20個。

-----個人理解

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末懊渡，一起剝皮案震驚了整個濱河市刽射，隨后出現(xiàn)的幾起案子，更是在濱河造成了極大的恐慌距贷，老刑警劉巖柄冲，帶你破解...
    沈念sama閱讀 216,402評論 6贊 499
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件，死亡現(xiàn)場離奇詭異忠蝗，居然都是意外死亡现横，警方通過查閱死者的電腦和手機，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,377評論 3贊 392
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進店門阁最，熙熙樓的掌柜王于貴愁眉苦臉地迎上來戒祠，“玉大人，你說我怎么就攤上這事速种〗” “怎么了？”我有些...
    開封第一講書人閱讀 162,483評論 0贊 353
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵配阵，是天一觀的道長馏颂。 經(jīng)常有香客問我，道長棋傍，這世上最難降的妖魔是什么救拉？ 我笑而不...
    開封第一講書人閱讀 58,165評論 1贊 292
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任，我火速辦了婚禮瘫拣，結(jié)果婚禮上亿絮，老公的妹妹穿的比我還像新娘。我一直安慰自己麸拄，他們只是感情好派昧，可當我...
    茶點故事閱讀 67,176評論 6贊 388
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布。 她就那樣靜靜地躺著拢切，像睡著了一般蒂萎。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上淮椰，一...
    開封第一講書人閱讀 51,146評論 1贊 297
  • 城市分裂傳說
    那天岖是，我揣著相機與錄音帮毁，去河邊找鬼。 笑死豺撑，一個胖子當著我的面吹牛烈疚，可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播聪轿，決...
    沈念sama閱讀 40,032評論 3贊 417
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼爷肝，長吁一口氣：“原來是場噩夢啊……” “哼！你這毒婦竟也來了陆错？” 一聲冷哼從身側(cè)響起灯抛，我...
    開封第一講書人閱讀 38,896評論 0贊 274
  • 萬榮殺人案實錄
    序言：老撾萬榮一對情侶失蹤，失蹤者是張志新（化名）和其女友劉穎音瓷，沒想到半個月后对嚼，有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體，經(jīng)...
    沈念sama閱讀 45,311評論 1贊 310
  • ?護林員之死
    正文 獨居荒郊野嶺守林人離奇死亡绳慎，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,536評論 2贊 332
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年纵竖，在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片杏愤。...
    茶點故事閱讀 39,696評論 1贊 348
  • 活死人
    序言：一個原本活蹦亂跳的男人離奇死亡靡砌，死狀恐怖，靈堂內(nèi)的尸體忽然破棺而出珊楼，到底是詐尸還是另有隱情通殃，我是刑警寧澤，帶...
    沈念sama閱讀 35,413評論 5贊 343
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布厕宗，位于F島的核電站画舌，受9級特大地震影響，放射性物質(zhì)發(fā)生泄漏已慢。R本人自食惡果不足惜曲聂，卻給世界環(huán)境...
    茶點故事閱讀 41,008評論 3贊 325
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望蛇受。 院中可真熱鬧句葵，春花似錦厕鹃、人聲如沸兢仰。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,659評論 0贊 22
  • 一樁弒父案剂碴，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽把将。三九已至，卻和暖如春忆矛，著一層夾襖步出監(jiān)牢的瞬間察蹲，已是汗流浹背请垛。 一陣腳步聲響...
    開封第一講書人閱讀 32,815評論 1贊 269
  • 情欲美人皮
    我被黑心中介騙來泰國打工， 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留洽议，地道東北人宗收。 一個月前我還...
    沈念sama閱讀 47,698評論 2贊 368
  • 代替公主和親
    正文 我出身青樓，卻偏偏與公主長得像亚兄，于是被迫代替她去往敵國和親混稽。 傳聞我的和親對象是個殘疾皇子，可洞房花燭夜當晚...
    茶點故事閱讀 44,592評論 2贊 353