https://classmethod.connpass.com/event/55140/ ã®ç™ºè¡¨è³‡æ–™ Goã®ä¸¦è¡Œå‡¦ç†ã«å¿…è¦ãªå¹¾ã¤ã‹ã®æ©Ÿèƒ½ã¨ã€ãれをã¤ã‹ã£ãŸã‚µãƒ³ãƒ—ルをã”紹介
Go並行処ç†ãƒã‚šã‚¿ãƒ¼ãƒ³
https://classmethod.connpass.com/event/55140/ ã®ç™ºè¡¨è³‡æ–™ Goã®ä¸¦è¡Œå‡¦ç†ã«å¿…è¦ãªå¹¾ã¤ã‹ã®æ©Ÿèƒ½ã¨ã€ãれをã¤ã‹ã£ãŸã‚µãƒ³ãƒ—ルをã”紹介
Go言語ã¨ä¸¦åˆ—処ç†
Go言語ã®ç‰¹å¾´ã¨ã—ã¦æŒ™ã’られる機能ã®1ã¤ã«ã€ã€Œä¸¦åˆ—処ç†ã‚’書ãã®ãŒç°¡å˜ã€ã¨ã„ã†ã‚‚ã®ãŒã‚ã‚Šã¾ã™ã€‚ ãã“ã§ä»Šå›žã¯ã€Goã«ãŠã‘る並列処ç†ã®æ©Ÿèƒ½ã‚’紹介ã—ã¦ã‹ã‚‰ã€ãã‚‚ãã‚‚ç¾ä»£ã®ã‚³ãƒ³ãƒ”ューターã§ã©ã®ã‚ˆã†ã«ã—ã¦ä¸¦åˆ—処ç†ãŒå®Ÿç¾ã•ã‚Œã¦ã„ã‚‹ã®ã‹ã‚’ã¨ã‚Šã‚ã’ã¾ã™ã€‚ 複数ã®ä»•äº‹ã‚’åŒæ™‚ã«è¡Œã†ã¨ã¯ï¼Ÿ 複数ã®ä»•äº‹ã‚’è¡Œã†ã“ã¨ã‚’表ã™è¨€è‘‰ã«ã¯ä¸¦è¡Œã¨ä¸¦åˆ—ã®2ã¤ãŒã‚ã‚Šã¾ã™ãŒã€ã“れらã«ã¯æ¬¡ã®ã‚ˆã†ãªåŒºåˆ¥ãŒã‚ã‚Šã¾ã™ã€‚ 並行処ç†ï¼ˆConcurrent） 並行（Concurrent）: CPU数・コア数ã®é™ç•Œã‚’超ãˆã¦è¤‡æ•°ã®ä»•äº‹ã‚’åŒæ™‚ã«è¡Œã†ã“㨠ã»ã‚“ã®å°‘ã—å‰ã¾ã§ã€ã‚³ãƒ³ãƒ”ューターã«æ載ã•ã‚Œã¦ã„ã‚‹CPUã¯ã‚³ã‚¢æ•°ãŒ1ã¤ã—ã‹ãªã„ã‚‚ã®ãŒæ™®é€šã§ã—ãŸã€‚ ãã®ã‚ˆã†ãªã€ä»Šã§ã¯ã‚‚ã†çµ¶æ»…å±æƒ§ç¨®ã«ãªã‚Šã¤ã¤ã‚るシングルコアã®ã‚³ãƒ³ãƒ”ューターã§ã‚ã£ã¦ã‚‚ã€ã‚¤ãƒ³ã‚¿ãƒ¼ãƒãƒƒãƒˆã‚’見ãªãŒã‚‰Wordã¨Excelã‚’ç«‹ã¡ä¸Šã’ã¦ãƒ¬ãƒãƒ¼ãƒˆã‚’書ã‘ã¾ã™ã€‚ ã“ã®å ´åˆã«å¤§äº‹ã«ãªã‚‹ã®ãŒä¸¦è¡Œï¼ˆConcurr
CRubyã®GVLã¨ãƒ“ジーループ - kyabã®æ—¥è¨˜
mrubyã®VMã®ãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰å¯¾å¿œãŒgithubã«ã¦è°è«–ã•ã‚Œã¦ã„ã¾ã™ã€‚ multi-thread support on the RiteVM #1657 自分もthread-safeãªVMãŒæ¬²ã—ã„ãªãã¨æ€ã£ã¦ã„ã¾ã™ã€‚STM32F4Discoveryã«FreeRTOS載ã›ã¦ä½¿ã£ã¦ã¿ãŸã„。 並行・並列処ç†ã®æˆ¦å›½æ™‚代? ã•ã¦ã€ãƒžãƒ«ãƒã‚³ã‚¢ãŒæ™®é€šã«ãªã£ãŸã—ã€Webアプリã®C10Kå•é¡ŒãŒã‚ã‚‹ã®ã§ä¸¦è¡Œãƒ»ä¸¦åˆ—処ç†ã¯æ˜¨ä»Šã®ãƒˆãƒ”ックã§ã™ï¼ˆå¤šåˆ†ï¼‰ã€‚ ãŸã マルãƒã‚¹ãƒ¬ãƒƒãƒ‰ãƒ—ãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã¯é›£ã—ã™ãŽï¼ã¨ã„ã†ã¯æ˜”ã‹ã‚‰è¨€ã‚ã‚Œã¦ã„ãŸã“ã¨ã§ã™ã€‚ ã§ã€ã‚‚ã†ã¡ã‚‡ã„並行・並列処ç†ã‚’書ãã‚„ã™ã出æ¥ãªã„ã®ã‹ã‚ˆï¼Ÿã¨ã„ã†ã“ã¨ã§Erlang,go,Scala(Actor),EventMachine,Thread pool ,node.js,deferred,future,java.util.concurrent色々出ã¦ãã¾ã—㟠（言語ã¨ãƒ©ã‚¤
Linux ã«ãŠã‘るスレッド数ã®ä¸Šé™ | yunabe.jp
並行 (Concurrent) 処ç†ã‚’実装ã™ã‚‹æ–¹æ³•ã¨ã—ã¦ã‚¹ãƒ¬ãƒƒãƒ‰ã¯éžå¸¸ã«å¼·åŠ›ãªãƒ„ールã§ã™ã€‚ スレッドを使ãˆã°åŒæ™‚ã«1ã¤ã®å‡¦ç†ã—ã‹è¡Œãˆãªã„æ—¢å˜ã®ãƒ—ãƒã‚°ãƒ©ãƒ ã«å¤§ããªä¿®æ£ã‚’åŠ ãˆã‚‹ã“ã¨ãªã〠並行処ç†ã‚’実装ã™ã‚‹ã“ã¨ãŒå¯èƒ½ã§ã™ã€‚ ã¾ãŸã‚¤ãƒ™ãƒ³ãƒˆã¨ã‚³ãƒ¼ãƒ«ãƒãƒƒã‚¯ã‚’複雑ã«çµ„ã¿åˆã‚ã›ãŸéžåŒæœŸçš„ãªãƒ—ãƒã‚°ãƒ©ãƒ ã«æ¯”ã¹ã¦ã€ åŒæœŸçš„ãªãƒ—ãƒã‚°ãƒ©ãƒ (例ãˆã°ãƒ•ã‚¡ã‚¤ãƒ«ã®èªã¿è¾¼ã¿ã«ã‚³ãƒ¼ãƒ«ãƒãƒƒã‚¯ãŒå‡ºã¦ããŸã‚Šã—ãªã„普通ã®ãƒ—ãƒã‚°ãƒ©ãƒ )㯠プãƒã‚°ãƒ©ãƒ ã®æµã‚Œã‚’自然ã«æ›¸ãã“ã¨ãŒã§ã〠å¯èªæ€§ãƒ»ä¿å®ˆæ€§ãƒ»ãƒ†ã‚¹ãƒˆã€ãƒ‡ãƒãƒƒã‚°ã®ã—ã‚„ã™ã•ã®é¢ã§é¥ã‹ã«å„ªã‚Œã¦ã„ã¾ã™ã€‚ スレッドを使ã†ã¨ãƒ—ãƒã‚°ãƒ©ãƒ ã‚’ãã‚Œã»ã©è¤‡é›‘・難èªåŒ–ã«ã›ãšã«ä¸¦è¡Œå‡¦ç†ãŒå®Ÿè£…ã§ãã¾ã™ã€‚ 一方ã§ã‚¹ãƒ¬ãƒƒãƒ‰ã‚’使ã£ãŸä¸¦è¡Œå‡¦ç†ã«ã¯æ¬ 点もã‚ã‚Šã¾ã™ã€‚ æ¬ ç‚¹ã®1ã¤ã¯ã€ã‚¹ãƒ¬ãƒƒãƒ‰ãƒ¢ãƒ‡ãƒ«ã§ã¯1ã¤ã®å‡¦ç†ã«å¯¾ã—ã¦1ã¤ã®ã‚¹ãƒ¬ãƒƒãƒ‰ã‚’用æ„ã™ã‚‹ã®ã§ã€ システムã®ã‚¹ãƒ¬ãƒƒãƒ‰æ•°ã®ä¸Šé™ã§åŒæ™‚ã«è¡Œãˆã‚‹å‡¦ç†ã®æ•°ãŒæ±ºã¾ã£ã¦ã—ã¾ã†ç‚¹ã§ã™ã€‚
Advanced Go Concurrency Patterns
Advanced Go Concurrency Patterns Sameer Ajmani Google Video This talk was presented at Google I/O in May 2013. Watch the talk on YouTube 2 Get ready 3 Go supports concurrency In the language and runtime, not a library. This changes how you structure your programs. 4 Goroutines and Channels Goroutines are independently executing functions in the same address space. go f() go g(1, 2) Channels are ty
Concurrent HaskellãŠã‚ˆã³Parallel Haskell
GHCã¯ã€ä¸¦è¡Œãƒ—ãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ãŠã‚ˆã³ä¸¦åˆ—プãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã«å¯¾å¿œã™ã‚‹ãŸã‚ã®ã€Haskellã¸ã®å¤§è¦æ¨¡ãªæ‹¡å¼µã‚’ã„ãã¤ã‹å®Ÿè£…ã—ã¦ã„る。ã¾ãšç”¨èªžã‚’ã¯ã£ãã‚Šã•ã›ã¦ãŠã“ã†ã€‚ 並列性(parallelism)ã¨ã¯ã€å®Ÿè¡Œæ€§èƒ½ã®å‘上を目的ã¨ã—ã¦ã€Haskellプãƒã‚°ãƒ©ãƒ を複数ã®ãƒ—ãƒã‚»ãƒƒã‚µä¸Šã§èµ°ã‚‰ã›ã‚‹ã“ã¨ã§ã‚る。ç†æƒ³çš„ã«ã¯ã€ã“ã‚Œã¯ä¸å¯è¦–ã«ã€æ„味を変更ã™ã‚‹ã“ã¨ãªã為ã•ã‚Œã‚‹ã¹ãã§ã‚る。 並行性(concurrency)ã¨ã¯ã€ãã‚Œãžã‚ŒIOã‚’è¡Œã†è¤‡æ•°ã®ã‚¹ãƒ¬ãƒƒãƒ‰ã‚’使ã£ã¦ãƒ—ãƒã‚°ãƒ©ãƒ を実装ã™ã‚‹ã“ã¨ã§ã‚る。確ã‹ã«ä¸¦è¡ŒHaskellプãƒã‚°ãƒ©ãƒ ã¯ä¸¦åˆ—ãªæ©Ÿæ¢°ä¸Šã§èµ°ã‚‰ã›ã‚‹ã“ã¨ãŒã§ãã‚‹ãŒã€ä¸¦è¡Œæ€§ã‚’使ã†ã®ã¯ã€ç¬¬ä¸€ç›®çš„ã¨ã—ã¦å®Ÿè¡Œæ€§èƒ½ã‚’å¾—ã‚‹ãŸã‚ã§ã¯ãªãã€ãã‚ŒãŒå½“該プãƒã‚°ãƒ©ãƒ を書ããŸã‚ã®æœ€ã‚‚å˜ç´”ã§æœ€ã‚‚直接的ãªæ–¹æ³•ã ã‹ã‚‰ã§ã‚る。スレッドã¯å…¥å‡ºåŠ›ã‚’è¡Œã†ã®ã§ã€ãƒ—ãƒã‚°ãƒ©ãƒ ã®æ„味ã¯å¿…然的ã«éžæ±ºå®šçš„ãªã‚‚ã®ã«ãªã‚‹ã€‚
マルãƒã‚³ã‚¢æ™‚代ã®æœ€æ–°ä¸¦åˆ—並行技術 Haskellã‹ã‚‰è¦‹ãˆã‚‹ä¸–ç•Œ
1 Haskell kazu@iij.ad.jp 2 (parallel) (concurrent) 3 4 5 6 7 Haskell 8 OS 9 Haskell 10 Haskell 11 Haskell Haskell 12 Haskell 13 Haskell 14 ) N 15 map map Google MapReduce 16 Java puzzles.parallel().map(e -> solve(e)); // Scala puzzles.par.map(solve); // Haskell map solve puzzles ‘using‘ parList rseq ) 17 % ghc -O2 -threaded foo.hs % ./foo +RTS -N2 18 Repa Accelerate GPU NVIDIA GPU CUDA 19 h x = do
Concurrent and Distributed Applications with Akka, Java and Scala
Concurrent and Distributed Applications with Akka, Java and Scala The document discusses concurrency and distribution in applications using Akka, Java and Scala. It covers key concepts like actors, messages and message passing in Akka. It describes how actors encapsulate state and behavior, communicate asynchronously via message passing and provide built-in concurrency without shared state or lock
2014 akka-streams-tokyo-japanese
Akka Streams (0.7) talk for the Tokyo Scala User Group, hosted by Dwango. Akka streams are an reactive streams implementation which allows for asynchronous back-pressured processing of data in complext pipelines. This talk aims to highlight the details about how reactive streams work as well as some of the ideas behind akka streams.Read less
Faster and scalable fast-logger
Yesod is a Haskell web framework for productive development of type-safe, RESTful, high performance web applications. As you may know, Michael and I released a set of packages for WAI 2.0 including Warp 2.x and fast-logger 2.x. They are much faster than their old versions. I will explain how I re-designed fast-logger in this article and how I improved the performance of Warp in the next one. The c
Goroutine Synchronization : D-7 <altijd in beweging>
（以下ã¯go 1.2.x時点ã§ã®è©±ã§ã™ã€‚å°†æ¥çš„ã«ä»•æ§˜ãŒã‹ã‚ã‚‹ã‹ã©ã†ã‹ã¯ã‚ã‹ã‚Šã¾ã›ã‚“） ã“れをèªã‚“ã§ã„ã¦ã€ã“ã†ã„ã†ã®æ°—ã«ã—ã¦ãªã„人多ã„ã‚“ã ã‚ã†ãªãƒ¼ã¨æ€ã£ã¦ã€æ›¸ã„ã¦ã¿ã¾ã™ã€‚å…ƒã®ãƒã‚¹ãƒˆã¯deferã®æŒ™å‹•ã«ã¤ã„ã¦èªžã£ã¦ã„るよã†ã«è¦‹å—ã‘られるã‘ã‚Œã©ã‚‚ã€ã“ã‚Œã¯è¦ã¯è¤‡æ•°ã‚¹ãƒ¬ãƒƒãƒ‰ã§å®Ÿè¡Œã•ã‚Œã‚‹ã‚³ãƒ¼ãƒ‰ã«ã¤ã„ã¦ã€ãƒ—ãƒã‚°ãƒ©ãƒ 終了時ã«åŒæœŸã¨ã‹å–ã‚ŠãŸããªã„ã€ã¨ã„ã†è©±ã ã¨æ€ã£ãŸã®ã§ã€ã“ã®ãƒã‚¹ãƒˆã®deferã‚’æ£ã—ãå‹•ã‹ã™ã«ã¯â€¦ã¨ã„ã†ã¨ã“ã‚ã‹ã‚‰ã©ã†ã„ã†å½¢ã§goroutineåŒå£«ã§åŒæœŸã‚’å–る方法ãŒã‚ã‚‹ã®ã‹ã€ä¸€ä¾‹ã‚’書ã出ã—ã¦ã„ãã¾ã™ã€‚ TL;DR; goã§ã„ãらgoroutineãŒæ°—軽ã«ã‹ã‘ã‚‹ã‹ã‚‰ã¨è¨€ã£ã¦ã€è¤‡æ•°ã‚¹ãƒ¬ãƒƒãƒ‰ã§å‡¦ç†ãŒè¡Œã‚ã‚Œã¦ã„ã‚‹ã®ã§åŒæœŸã¯ã‚ãƒãƒ³ã¨ã‚„らãªã„ã¨ãƒ€ãƒ¡ã§ã™ã‚ˆã€‚ deferã®åŸºæœ¬ goã§ã¯LLã®ãƒŽãƒªã§ã‚³ãƒ¼ãƒ‰ã‚’書ã‘ã‚‹ã®ãŒå£²ã‚Šã®ä¸€ã¤ã§ã™ãŒã€ãƒ¡ãƒ¢ãƒªç®¡ç†ã¯ã—ã¦ãれるもã®ã®ã€æ§˜ã€…ãªãƒªã‚½ãƒ¼ã‚¹è§£æ”¾ã‚‚å…¨ã¦è‡ªå‹•ã¨ã„ã†ã‚ã‘ã§ã¯ã‚ã‚Š
ExecutorService ã®å¾©ç¿’ - Qiita
Android ã§éžåŒæœŸå‡¦ç†ã£ã¦ã„ã†ã¨ã€çœŸã£å…ˆã« AsyncTask ãŒå‡ºã¦ãã‚‹ã‚“ã§ã™ãŒã€ãªã‚‹ã¹ããªã‚‰ Java 標準ã®ãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰API ã§ã‚ã‚‹ ExecutorService を使ã£ãŸæ–¹ãŒè‰¯ã„ã¨æ€ã£ã¦ã¾ã™ã€‚ (2007å¹´ã®è¨˜äº‹ã ã‘ã©) Java技術最å‰ç·š - 「Java SE 6完全攻略ã€ç¬¬49回 Concurrency Utilitiesã®å¤‰æ›´ç‚¹ ãã®1：ITpro Android ã§åˆã‚㦠Java を書ã„ãŸã®ã§ç´°ã‹ã„仕様ãŒã‚ˆã分ã‹ã‚‰ãšã€å‹‰å¼·ãŒã¦ã‚‰å‹•ãを確èªã—ã¦ã¿ã¾ã—ãŸã€‚ 1. 1ã¤ã®ãƒ¯ãƒ¼ã‚«ã‚¹ãƒ¬ãƒƒãƒ‰ã«å®Ÿè¡Œã•ã›ã‚‹ newSingleThreadExecutor ã§ãƒ¯ãƒ¼ã‚«ã‚¹ãƒ¬ãƒƒãƒ‰ã‚’一ã¤æŒã¤ Executor を生æˆã—ã¦ã€2ã¤ã®ã‚¿ã‚¹ã‚¯(=éžåŒæœŸã§å®Ÿè¡Œã•ã›ã‚‹å‡¦ç†)ã‚’é †ã«å®Ÿè¡Œã€‚ public void singleThreadExecutorBasicTest() throws Excep
Fork/Join ã§ä¸¦åˆ—å’Œ - å€ãƒžãƒ³'s BLOG
å‰å›ž Java 7 を使ã†ç’°å¢ƒè¨å®šã‚’è¡Œã£ãŸã®ã§ã€ã¤ã„ã§ã«ã¡ã‚‡ã£ã¨ Java 7 ã‚’ã„ã˜ã£ã¦ã¿ã¾ã™*1。　今回見ã¦ã„ãã®ã¯ java.util.concurrent パッケージã«è¿½åŠ ã•ã‚ŒãŸ Fork/Join フレームワークã§ã™ã€‚　Fork/Join ã¯å¤§é‡ã®è¨ˆç®—ã‚’å°ã•ã„部分ã«åˆ†ã‘ã¦ãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰ã§è¨ˆç®—ã™ã‚‹æ‰‹æ³•ã§ã™ã€‚ ã§ã€ã“ã®è¨˜äº‹ã§ã¯æ•´æ•°ã®ãƒªã‚¹ãƒˆ (List<Integer>) ã‚’å—ã‘å–ã£ã¦ãã®è¦ç´ å…¨ã¦ã®å’Œã‚’計算ã™ã‚‹ã‚³ãƒ¼ãƒ‰ã‚’見ã¦ã„ãã¾ã™ã€‚ å‚考 URL Java ãƒãƒ¥ãƒ¼ãƒˆãƒªã‚¢ãƒ« 「Fork/Join〠Javadoc ForkJoinPool ForkJoinTask RecursiveTask GPars Reference Documentation 「3.6. Fork-Join〠java.util.concurrent パッケージ ： Java 7 Java 7 㧠Fork/Jo
マルãƒã‚³ã‚¢æ™‚代ã®"ãƒ‡ãƒ¼ã‚¿æ§‹é€ ã¨ã‚¢ãƒ«ã‚´ãƒªã‚ºãƒ "å†å…¥é–€
ãƒ‡ãƒ¼ã‚¿æ§‹é€ ã¨ã‚¢ãƒ«ã‚´ãƒªã‚ºãƒ å†å…¥é–€ ã¯ã˜ã‚㫠・並{è¡Œ|列} & {Lock|Wait}Free ・ABA & ABA' ・volatile ＆ メモリãƒãƒªã‚¢ ・プリミティブ ・CAS ・MCAS ・STM ・メモリ管ç†:free & GC ・Toots List & Skiplist [å˜æ–¹å‘List] ・リスト ・細粒度リスト ・Lazyリスト ・Lock-Freeリスト ・Lock-Freeリスト2 [SkipList] ・スã‚ップリスト ・Lazyスã‚ップリスト ・Lock-freeスã‚ップリスト [åŒæ–¹å‘List] Queue & PriorityQueue [UnBounded Queue] ・Queue ・CAS based Lock-Free Queue ・LL/SC based Lock-Free Queue [Unbounded Priority Queue] ・Heap
High performance networking on the JVM
Red Hat (JBoss) - EAP Core Team Former contractor for Apple Inc Author - Netty in Action Apache Software Foundation Member Netty  / Vert.x Core-Developer and all things NIO Java and Scala Twitter: @normanmaurer Github: https://github.com/normanmaurer As always, only optimize if you really need! 1000 concurrent connections != high-scale If you only need to handle a few hundred connections use Block
ランã‚ング
ãŠçŸ¥ã‚‰ã›
ランã‚ング
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
JVM ã®ä¸¦è¡Œæ€§: Java 8 ã§ã®ä¸¦è¡Œå‡¦ç†ã®åŸºç¤Ž
Java ã®ç†è«–ã¨å®Ÿè·µ: フォークを活用ã™ã‚‹ã€ç¬¬ 2 回 Java 7ã®ParallelArrayクラスを使ã£ã¦ã‚½ãƒ¼ãƒˆã¨æ¤œç´¢ã®é€Ÿåº¦ã‚’上ã’ã‚‹
Java ã®ç†è«–ã¨å®Ÿè·µ: Java 7ã§ç™»å ´ã™ã‚‹ãƒ•ã‚©ãƒ¼ã‚¯/ジョインã®ãƒ•ãƒ¬ãƒ¼ãƒ ワークを使ã£ã¦ç´°ç²’度並列処ç†ã®æ´»ç”¨æ–¹æ³•ã‚’å¦ã¶
Efficient data transfer through zero copy
IBM Developer
{{#tags}}- {{label}}
{{/tags}}