Cassandra 2.0 ã« CAS ãŒå…¥ã‚‹ã¨ã‹å…¥ã‚‰ãªã„ã¨ã‹ - kuenishi's blog
CASSANDRA-5062ã§CAS (Compare and Swap) を入れよã†ã¨ã„ã†è©±ã«ãªã£ã¦ã„るらã—ãã€ä¸€ä½“ã©ã‚“ãªã™ã”ã„アトミックブãƒãƒ¼ãƒ‰ã‚ャストを使ã†ã®ã‹æ°—ã«ãªã£ã¦ã„ãŸã€‚ã©ã†ã„ã†ã“ã¨ãªã®ã ã‚ã†ã¨ã‚¹ãƒ¬ãƒƒãƒ‰ã‚’ナナメèªã¿ã—ã¦ã¿ãŸã®ã ãŒâ€¦è°è«–ã®æµã‚Œã¨ã—ã¦ã¯ カウンターã ã‘ã˜ã‚ƒãªãã¦CASã»ã—ã„よãAPIã¨ã—㦠ZooKeeperã®ãƒãƒƒã‚¯ä½¿ã†ã®ãŒã‚·ãƒ³ãƒ—ルã§ã„ã‚“ã˜ã‚ƒã？ ã„ã‚„ã„やサーãƒãƒ¼ã®ç¨®é¡žå¢—ã‚„ã™ã¨ã‹ã‚ã‚Šå¾—ãªã„㗠基本方é‡ã¯ã€ã‚³ãƒ¼ãƒ‡ã‚£ãƒãƒ¼ã‚¿ãƒ¼ã¿ãŸã„ãªã®ã‚’レプリカセット毎ã«æ±ºã‚ã¦ãã“ã‹ã‚‰ Chain Replication ã½ã コーディãƒãƒ¼ã‚¿ãƒ¼ã©ã†ã‚„ã£ã¦æ±ºã‚ã‚‹ ã‚„ã£ã±Paxosã˜ã‚ƒã？ å†å®Ÿè£…ヤダよZAB使ãŠã†ã‚ˆZKã®å®Ÿè£…ã‚るよ （ãªã‚“ã‹ãƒ—ãƒãƒˆã‚³ãƒ«ä¸Šã®ç†ç”±ãŒã‚ã£ã¦ï¼‰ã‚„ã£ã±Paxos実装ã™ã‚‹ã—ã‹ãªã„ã‹â€¦ ã¨ãªã£ã¦ã€çµå±€ Jonathan Ellis ㌠Paxos ã‚’ç´ ã§å®Ÿè£…ã—ã¦ã—ã¾ã£ãŸæ¨¡
『マルãƒã‚¹ãƒ¬ãƒƒãƒ‰ãƒ—ãƒã‚°ãƒ©ãƒ （ãã®ï¼•ãらã„？）ã€
ã‚‚ã†ã€ãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰é£½ãã¦ããŸãƒ»ãƒ»ãƒ»ãƒ» æ°—ã‚’å–ã‚Šç›´ã—ã¦ã€å‰å›žãŠè©±ã—ãŸLOCK FREEã®æ¦‚念を使ã£ã¦ スタックを作り直ã—ã¦ã¿ã¾ã—ょã†ã€‚ 基本的ãªå†…容ã¯å¤‰ã‚ã‚Šã¾ã›ã‚“。 æ§‹é€ ä½“ã‚‚ã¾ã‚‹ã£ãã—åŒã˜ã§ã™ã€‚ template <class T> class lock_free_stack : protected boost::noncopyable { protected: struct snode_type{ T* value; snode_type* next; snode_type(T* nin_value,snode_type* nin_next) : value( nin_value ) , next( nin_next ) {} }; snode_type* tail; snode_type* dummy; unsigned int counter; public: //constract
Lock-freeã¨Wait-freeアルゴリズム- Wikipedia
Lock-freeã¨Wait-freeアルゴリズムã¨ã¯ã€å…±æœ‰ãƒ‡ãƒ¼ã‚¿ã«ãƒãƒƒã‚¯ã‚’ã‹ã‘ã¦ã‚¢ã‚¯ã‚»ã‚¹ã‚’防ãアルゴリズムã¨ã¯é•ã„ã€è¤‡æ•°ã®ã‚¹ãƒ¬ãƒƒãƒ‰ãŒåŒæ™‚並行的ã«ã€ã‚る対象データを壊ã™ã“ã¨ãªã—ã«èªã¿æ›¸ãã™ã‚‹ã“ã¨ã‚’å¯èƒ½ã«ã™ã‚‹ã‚¢ãƒ«ã‚´ãƒªã‚ºãƒ ã§ã‚る。Lock-free ã¨ã¯ã‚¹ãƒ¬ãƒƒãƒ‰ãŒãƒãƒƒã‚¯ã—ãªã„ã“ã¨ã‚’æ„味ã—ã¦ãŠã‚Šã€å…¨ã¦ã®ã‚¹ãƒ†ãƒƒãƒ—ã«ãŠã„ã¦ã‚·ã‚¹ãƒ†ãƒ ãŒå¿…ãšé€²è¡Œã™ã‚‹ã€‚ã“ã‚Œã¯Lock-free ã§ã¯ãƒŸãƒ¥ãƒ¼ãƒ†ãƒƒã‚¯ã‚¹ã‚„セマフォã¨ã„ã£ãŸã€æŽ’他制御ã®ãŸã‚ã®ãƒ—リミティブを使ã£ã¦ã¯ãªã‚‰ãªã„ã“ã¨ã‚’æ„味ã™ã‚‹ã€‚ãªãœãªã‚‰ãƒãƒƒã‚¯ã‚’æŒã£ã¦ã„るスレッドã®å®Ÿè¡ŒãŒä¸æ–ã—ãŸå ´åˆã€å…¨ä½“ã®é€²è¡Œã‚’阻æ¢ã—ã†ã‚‹ã‹ã‚‰ã§ã‚る。Wait-free ã¨ã¯ã€ä»–ã®ã‚¹ãƒ¬ãƒƒãƒ‰ã®å‹•ä½œã«é–¢ä¿‚ãªãã€ã‚¹ãƒ¬ãƒƒãƒ‰ãŒã„ã‹ãªã‚‹æ“作も有é™ã®ã‚¹ãƒ†ãƒƒãƒ—ã§æ“作を完了ã•ã›ã‚‰ã‚Œã‚‹ã“ã¨ã‚’指ã™ã€‚ã‚るアルゴリズムãŒLock-freeã§ã‚ã‚‹ãŒWait-freeã§ãªã„ã“ã¨ã¯ã‚ã‚Šã†ã‚‹ã€‚Wait-free ãªã‚¢ãƒ«ã‚´ãƒªã‚ºãƒ
コンペア・アンド・スワップ - Wikipedia
コンペア・アンド・スワップ（Compare-and-Swapã€CAS）ã¯ã€CPUã®ç‰¹åˆ¥ãªå‘½ä»¤ã®ä¸€ç¨®ã€‚ä¸å¯åˆ†æ“作ã¨ã—ã¦ã€ã‚るメモリä½ç½®ã®å†…容ã¨æŒ‡å®šã•ã‚ŒãŸå€¤ã‚’比較ã—ã€ç‰ã—ã‘ã‚Œã°ãã®ãƒ¡ãƒ¢ãƒªä½ç½®ã«åˆ¥ã®æŒ‡å®šã•ã‚ŒãŸå€¤ã‚’æ ¼ç´ã™ã‚‹ã€‚ã“ã®æ“作ã®çµæžœã€ç½®æ›ãŒè¡Œã‚ã‚ŒãŸã‹ã©ã†ã‹ã‚’示ã™å¿…è¦ãŒã‚ã‚Šã€å˜ç´”ãªçœŸç†å€¤ã‚’è¿”ã™ã‹ã€ãã®ãƒ¡ãƒ¢ãƒªä½ç½®ã‹ã‚‰èªã¿è¾¼ã‚“ã 内容（書ã込んã 内容ã§ã¯ãªã„）を返ã™ã€‚ CAS命令ã¯ã€ãƒžãƒ«ãƒãƒ—ãƒã‚»ãƒƒã‚µã‚·ã‚¹ãƒ†ãƒ ã§ã‚»ãƒžãƒ•ã‚©ãªã©ã‚’実装ã™ã‚‹ã®ã«ä½¿ã‚れる。マルãƒãƒ—ãƒã‚»ãƒƒã‚µã‚·ã‚¹ãƒ†ãƒ ã§Lock-freeã¨Wait-freeアルゴリズムを実装ã™ã‚‹ã®ã«ã‚‚使ã‚れる。 Maurice Herlihy (1993å¹´) ã¯ã€CAS命令ãŒå˜ãªã‚‹ãƒªãƒ¼ãƒ‰ã€ãƒ©ã‚¤ãƒˆã‚„テスト・アンド・セットã§ã¯å®Ÿè£…ã§ããªã„ã“ã¨ã‚’示ã—ãŸ[1]。 CAS命令を利用ã—ãŸã‚¢ãƒ«ã‚´ãƒªã‚ºãƒ ã¯ã€ä¸€èˆ¬ã«ã‚ã‚‹ã‚ーã¨ãªã‚‹ãƒ¡ãƒ¢ãƒªä½ç½®ã‚’èªã¿å–ã‚Šã€ãã®å¤ã„値を記憶ã—ã¦ãŠã。ãã®å¤ã„
1
ランã‚ング
ãŠçŸ¥ã‚‰ã›
ランã‚ング
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
New features in Cassandra 2.0 – More on Lightweight Transactions - OpenCredo%252Flinux2.6)
http://hira-consulting.com/wiki/index.php?__cmpxchg%28%29%2Flinux2.6
{{#tags}}- {{label}}
{{/tags}}