流程解讀
Puma 進(jìn)程（可以有一個(gè)或多個(gè)）通過 Reactor類中的線程來接受來自套接字的連接。連接一旦完全緩沖并讀取，就會(huì)移到 todo 列表中，可用的線程會(huì)從那里拾取它
在集群模式下，首先啟動(dòng)一個(gè) master 進(jìn)程，它會(huì)準(zhǔn)備應(yīng)用程序，然后使用 fork() 系統(tǒng)調(diào)用創(chuàng)建一個(gè)或多個(gè) child 進(jìn)程。這些 child 進(jìn)程都監(jiān)聽同一個(gè)套接字。master 進(jìn)程不監(jiān)聽套接字或處理請(qǐng)求，它的主要目的是管理和監(jiān)聽 UNIX 信號(hào)，并可能kill或啟動(dòng) child 進(jìn)程。
我們有時(shí)將 child 進(jìn)程（或單進(jìn)程模式下的 Puma 進(jìn)程）稱為 worker，有時(shí)將 Puma 的 ThreadPool:創(chuàng)建的線程稱為 worker 線程。
啟動(dòng)時(shí)，Puma 會(huì)監(jiān)聽一個(gè) TCP 或 UNIX 套接字。
該套接字的 backlog 默認(rèn)配置為 1024，但實(shí)際的 backlog 值會(huì)受到 net.core.somaxconn sysctl 值的限制。
backlog 決定了未接受連接的隊(duì)列大小。如果 backlog 已滿，操作系統(tǒng)將不會(huì)接受新的連接。
當(dāng)至少有一個(gè) worker 線程可用于工作時(shí)，reactor 線程會(huì)監(jiān)聽套接字并接受請(qǐng)求（如果有等待的請(qǐng)求）。
- reactor 線程會(huì)等待整個(gè) HTTP 請(qǐng)求接收完成。
- Puma 會(huì)將等待接收 HTTP 請(qǐng)求體所花費(fèi)的時(shí)間以毫秒為單位暴露給 Rack 應(yīng)用，作為 env['puma.request_body_wait']。
- 一旦完全緩沖并接收，連接就會(huì)被推送到 "todo" 集合中。
- worker 線程從 "todo" 集合中彈出工作進(jìn)行處理。
- worker 線程通過調(diào)用配置的 Rack 應(yīng)用來處理請(qǐng)求。Rack 應(yīng)用生成 HTTP 響應(yīng)。
- worker 線程將響應(yīng)寫入到連接。雖然 Puma 通過單獨(dú)的線程緩沖請(qǐng)求，但它不會(huì)為響應(yīng)使用單獨(dú)的線程。
- 完成之后，線程變?yōu)榭捎?，可以處?"todo" 集合中的另一個(gè)連接。
源碼解讀
cli里初始化Launcher并調(diào)用#run方法
Launcher#run里調(diào)用runner(cluster)的run
Cluster#run調(diào)用 #spawn_workers啟動(dòng)進(jìn)程
啟動(dòng)配置workers數(shù)量 - 已啟動(dòng)workers數(shù)量(工作進(jìn)程)
spawn_workers方法在cluster的run方法內(nèi)循環(huán)調(diào)用
cluster的spawn_worker繼續(xù)調(diào)用worker方法，初始化worker(這里fork進(jìn)程執(zhí)行)并執(zhí)行run
worker方法里start_server啟動(dòng)server，并給到worker
worker run方法里處理一些信號(hào)量；主要是啟動(dòng)了server.run
start_server獲取到binder(io，如socket和tcp_listener等)
server.run 方法，啟動(dòng)線程池；
調(diào)用server.handle_servers，開始io多路復(fù)用(select)
這里我們先記住，同時(shí)啟動(dòng)了 清理空閑線程
使用client 并放入線程池
thread_pool里 << 把任務(wù)放入@todo里(使用mutex等保證線程安全)，且 線程未創(chuàng)建滿時(shí)(小于最大數(shù)量)，再起新線程(span_thread)
spawn_thread后線程內(nèi)
while true 無限循環(huán)，從todo里取出work，并執(zhí)行block.call(work)
block是創(chuàng)建時(shí)傳入的process_client
process_client又調(diào)用
handle_request，handle_request里最終出現(xiàn)了我們熟悉的@app.call
process_client會(huì)接著調(diào)用prepare_response -> fast_write_response 最終往io里寫入了http response，整個(gè)流程完成
自動(dòng)清理空閑線程
循環(huán)中遇到 todo為空，且有空閑線程清理標(biāo)識(shí)，結(jié)束當(dāng)前線程
