トップ «前の日記(2014-02-24) 最新 次の日記(2014-02-26)» 編集

ヨタの日々

2001|08|09|10|11|12|
2002|01|02|03|04|05|06|07|08|09|10|11|12|
2003|01|02|03|04|05|06|07|08|09|10|11|12|
2004|01|02|03|04|05|06|07|08|09|10|11|12|
2005|01|02|03|04|05|06|07|08|09|10|11|12|
2006|01|02|03|04|05|06|07|08|09|10|11|12|
2007|01|02|03|04|05|06|07|08|09|10|11|12|
2008|01|02|03|04|05|06|07|08|09|10|11|12|
2009|01|02|03|04|05|06|07|08|09|10|11|12|
2010|01|02|03|04|05|06|07|08|09|10|11|12|
2011|01|02|03|04|05|06|07|08|09|10|11|12|
2012|01|02|03|04|05|06|07|08|09|10|11|12|
2013|01|02|03|04|05|06|07|08|09|10|11|12|
2014|01|02|03|04|05|06|07|08|09|10|11|12|
2015|01|02|03|04|05|06|07|08|09|10|11|12|
2016|01|02|03|04|05|06|07|08|09|10|11|12|
2017|01|02|03|04|05|06|07|08|09|10|11|12|
2018|01|02|03|04|05|06|07|08|09|10|11|12|
2019|01|02|03|04|05|06|07|08|09|10|11|12|
2020|01|02|03|04|05|06|07|08|09|10|11|12|
2021|01|02|03|04|05|06|07|08|09|10|11|12|
2022|01|02|03|04|05|06|07|08|09|10|11|12|
2023|01|02|03|04|05|06|07|08|12|
2024|01|02|03|

2014-02-25 :-(

_ 午前

0530 起床

0710 食堂

0830 出勤 || デバッグしTARI

_ 午後

1300 デバッグしTARI

_

1730 退勤

1830 リポジトリ整理したり

2100 飯。鮭のムニエル

2200 リポジトリ整理したり

_ [Java][Ruby][マルチスレッド][デザインパターン]Java言語で学ぶデザインパターン入門マルチスレッド編 Worker Thread - 仕事が来るまで待ち、仕事が来たら働く

予め起動しておいたスレッドへ仕事を投げる。

apache web server とかでもお馴染み。

# coding: utf-8

#
# 『増補改訂版Java言語で学ぶデザインパターン入門マルチスレッド編』 http://www.hyuki.com/dp/dp2.html
# 
# Worker Thread - 仕事が来るまで待ち、仕事が来たら働く
#

require 'thread'
require 'monitor'

MAX_REQUEST = 100

class Channel
  def initialize(threads)
    @lock = Monitor.new()
    @cond = @lock.new_cond()
    @requestQueue = Array.new(MAX_REQUEST)
    @head = 0;    # 次にtakeRequestする場所
    @tail = 0;    # 次にputRequestする場所
    @count = 0;   # Requestの数
    @threadPool = Array.new(threads)
  end
  
  def startWorkers()
    # join() するとブロックするのでやってはいけない
    0.upto(@threadPool.length - 1) {|i|
      @threadPool[i] = WorkerThread.new("Worker-#{i}", self)
    }
  end
  
  def putRequest(request)
    @lock.synchronize {
      while (@count >= @requestQueue.length)
        begin
          @cond.wait()
        rescue => ex
          puts ex
        end
      end
      @requestQueue[@tail] = request
      @tail = (@tail + 1) % @requestQueue.length
      @count += 1
      @cond.broadcast()
    }
  end

  def takeRequest()
    @lock.synchronize {
      while (@count <= 0)
        begin
          @cond.wait();
        rescue => ex
          puts ex
        end
      end
      request = @requestQueue[@head]
      @head = (@head + 1) % @requestQueue.length;
      @count -= 1
      @cond.broadcast()
      return request
    }
  end
end

class Request
  def initialize(name, number)
    @name = name      # 依頼者
    @number = number  # リクエストの番号
  end
  
  def execute()
    puts "#{Thread.current} executes #{to_s}"
    begin
      sleep(0.1)
    rescue => ex
      puts ex
    end
  end
  
  def to_s()
    return "[ Request from #{@name} No. #{@number} ]"
  end
  
end

class ClientThread < Thread
  def initialize(name, channel)
    @channel = channel
    @name = name
    
    block = Proc.new {
      begin
        i = 0
        while true
          request = Request.new(@name, i);
          @channel.putRequest(request)
          sleep(0.1)
          i += 1
        end
      rescue => ex
        puts ex
      end
      
    }
    super(&block)
  end
end

class WorkerThread < Thread
  def initialize(name, channel)
    @channel = channel
    
    block = Proc.new {
      while true
        request = @channel.takeRequest()
        request.execute()
      end
    }
    super(&block)
  end
end

def main(argv)
  th ||= []
  channel = Channel.new(5);   # ワーカースレッドの個数
  channel.startWorkers()
  th << ClientThread.new("Alice", channel)
  th << ClientThread.new("Bobby", channel)
  th << ClientThread.new("Chris", channel)
  th.each {|t| t.join() }
end

main(ARGV)
>ruby WorkerThread.rb
#<WorkerThread:0x00000002bc7760> executes [ Request from Alice No. 0 ]
#<WorkerThread:0x0000000031bde8> executes [ Request from Bobby No. 0 ]
#<WorkerThread:0x0000000031bb18> executes [ Request from Chris No. 0 ]
#<WorkerThread:0x0000000031b690> executes [ Request from Chris No. 1 ]
#<WorkerThread:0x00000002bc7760> executes [ Request from Alice No. 1 ]
#<WorkerThread:0x0000000031bb18> executes [ Request from Bobby No. 1 ]
#<WorkerThread:0x0000000031bde8> executes [ Request from Alice No. 2 ]
#<WorkerThread:0x0000000031b690> executes [ Request from Chris No. 2 ]
#<WorkerThread:0x0000000031b8c0> executes [ Request from Bobby No. 2 ]
#<WorkerThread:0x0000000031bde8> executes [ Request from Chris No. 3 ]
#<WorkerThread:0x0000000031bb18> executes [ Request from Alice No. 3 ]
#<WorkerThread:0x0000000031b690> executes [ Request from Bobby No. 3 ]
#<WorkerThread:0x0000000031bb18> executes [ Request from Alice No. 4 ]
#<WorkerThread:0x00000002bc7760> executes [ Request from Chris No. 4 ]
#<WorkerThread:0x0000000031b8c0> executes [ Request from Bobby No. 4 ]
#<WorkerThread:0x0000000031b690> executes [ Request from Alice No. 5 ]
以下略

ライセンス

Copyright (C) 2002,2006 Hiroshi Yuki.
http://www.hyuki.com/dp/dp2.html
hyuki@hyuki.com

This software is provided 'as-is', without any express or implied warranty.
In no event will the authors be held liable for any damages
arising from the use of this software.

Permission is granted to anyone to use this software for any purpose,
including commercial applications, and to alter it and redistribute it freely,
subject to the following restrictions:

1. The origin of this software must not be misrepresented; you must not claim
that you wrote the original software. If you use this software in a product,
an acknowledgment in the product documentation would be appreciated but is not
required.

2. Altered source versions must be plainly marked as such, and must not be
misrepresented as being the original software.

3. This notice may not be removed or altered from any source distribution.

参考

『増補改訂版Java言語で学ぶデザインパターン入門マルチスレッド編』

4797331623