<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
<head>
<title>Rumai::IXP::Agent::RangedPool</title>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<link rel="stylesheet" href="../../../../css/reset.css" type="text/css" media="screen" />
<link rel="stylesheet" href="../../../../css/main.css" type="text/css" media="screen" />
<script src="../../../../js/jquery-1.3.2.min.js" type="text/javascript" charset="utf-8"></script>
<script src="../../../../js/jquery-effect.js" type="text/javascript" charset="utf-8"></script>
<script src="../../../../js/main.js" type="text/javascript" charset="utf-8"></script>
</head>
<body>
<div class="banner">
<h1>
<span class="type">Class</span>
Rumai::IXP::Agent::RangedPool
<span class="parent"><
<a href="../../../Object.html">Object</a>
</span>
</h1>
<ul class="files">
<li><a href="../../../../files/lib/rumai/ixp/transport_rb.html">lib/rumai/ixp/transport.rb</a></li>
</ul>
</div>
<div id="bodyContent">
<div id="content">
<div class="description">
<p>
A finite, thread-safe pool of range members.
</p>
</div>
<div class="sectiontitle">Methods</div>
<dl class="methods">
<dt>N</dt>
<dd>
<ul>
<li><a href="#M000045">new</a></li>
</ul>
</dd>
<dt>O</dt>
<dd>
<ul>
<li><a href="#M000048">obtain</a></li>
</ul>
</dd>
<dt>R</dt>
<dd>
<ul>
<li><a href="#M000052">release</a></li>
</ul>
</dd>
</dl>
<div class="sectiontitle">Constants</div>
<table border='0' cellpadding='5'>
<tr valign='top'>
<td class="attr-name">FILL_RATE</td>
<td>=</td>
<td class="attr-value">10</td>
</tr>
<tr valign='top'>
<td> </td>
<td colspan="2" class="attr-desc"><p>
how many new members should be added to the pool when the pool is empty?
</p>
</td>
</tr>
</table>
<div class="sectiontitle">Class Public methods</div>
<div class="method">
<div class="title" id="M000045">
<a name="M000045"></a><b>new</b>(range)
</div>
<div class="sourcecode">
<p class="source-link">
Source: <a href="javascript:toggleSource('M000045_source')" id="l_M000045_source">show</a>
| <a href="http://github.com/sunaku/rumai/blob/5fcf09b89976a53dd9346e335a1803b337e0c447/lib/rumai/ixp/transport.rb#L66" target="_blank" class="github_url">on GitHub</a>
</p>
<div id="M000045_source" class="dyn-source">
<pre><span class="ruby-comment cmt"># File lib/rumai/ixp/transport.rb, line 66</span>
<span class="ruby-keyword kw">def</span> <span class="ruby-identifier">initialize</span> <span class="ruby-identifier">range</span>
<span class="ruby-ivar">@pos</span> = <span class="ruby-identifier">range</span>.<span class="ruby-identifier">first</span>
<span class="ruby-ivar">@lim</span> = <span class="ruby-identifier">range</span>.<span class="ruby-identifier">last</span>
<span class="ruby-ivar">@lim</span> = <span class="ruby-ivar">@lim</span>.<span class="ruby-identifier">succ</span> <span class="ruby-keyword kw">unless</span> <span class="ruby-identifier">range</span>.<span class="ruby-identifier">exclude_end?</span>
<span class="ruby-ivar">@pool</span> = <span class="ruby-constant">Queue</span>.<span class="ruby-identifier">new</span>
<span class="ruby-keyword kw">end</span></pre>
</div>
</div>
</div>
<div class="sectiontitle">Instance Public methods</div>
<div class="method">
<div class="title" id="M000048">
<a name="M000048"></a><b>obtain</b>()
</div>
<div class="description">
<p>
Returns an unoccupied range member from the pool.
</p>
</div>
<div class="sourcecode">
<p class="source-link">
Source: <a href="javascript:toggleSource('M000048_source')" id="l_M000048_source">show</a>
| <a href="http://github.com/sunaku/rumai/blob/5fcf09b89976a53dd9346e335a1803b337e0c447/lib/rumai/ixp/transport.rb#L75" target="_blank" class="github_url">on GitHub</a>
</p>
<div id="M000048_source" class="dyn-source">
<pre><span class="ruby-comment cmt"># File lib/rumai/ixp/transport.rb, line 75</span>
<span class="ruby-keyword kw">def</span> <span class="ruby-identifier">obtain</span>
<span class="ruby-keyword kw">begin</span>
<span class="ruby-ivar">@pool</span>.<span class="ruby-identifier">deq</span> <span class="ruby-keyword kw">true</span>
<span class="ruby-keyword kw">rescue</span> <span class="ruby-constant">ThreadError</span>
<span class="ruby-comment cmt"># pool is empty, so fill it</span>
<span class="ruby-constant">FILL_RATE</span>.<span class="ruby-identifier">times</span> <span class="ruby-keyword kw">do</span>
<span class="ruby-keyword kw">if</span> <span class="ruby-ivar">@pos</span> <span class="ruby-operator">!=</span> <span class="ruby-ivar">@lim</span>
<span class="ruby-ivar">@pool</span> <span class="ruby-operator"><<</span> <span class="ruby-ivar">@pos</span>
<span class="ruby-ivar">@pos</span> = <span class="ruby-ivar">@pos</span>.<span class="ruby-identifier">succ</span>
<span class="ruby-keyword kw">else</span>
<span class="ruby-comment cmt"># range is exhausted, so give other threads</span>
<span class="ruby-comment cmt"># a chance to fill the pool before retrying</span>
<span class="ruby-constant">Thread</span>.<span class="ruby-identifier">pass</span>
<span class="ruby-keyword kw">break</span>
<span class="ruby-keyword kw">end</span>
<span class="ruby-keyword kw">end</span>
<span class="ruby-keyword kw">retry</span>
<span class="ruby-keyword kw">end</span>
<span class="ruby-keyword kw">end</span></pre>
</div>
</div>
</div>
<div class="method">
<div class="title" id="M000052">
<a name="M000052"></a><b>release</b>(member)
</div>
<div class="description">
<p>
Marks the given member as being unoccupied so that it may be occupied again
in the future.
</p>
</div>
<div class="sourcecode">
<p class="source-link">
Source: <a href="javascript:toggleSource('M000052_source')" id="l_M000052_source">show</a>
| <a href="http://github.com/sunaku/rumai/blob/5fcf09b89976a53dd9346e335a1803b337e0c447/lib/rumai/ixp/transport.rb#L99" target="_blank" class="github_url">on GitHub</a>
</p>
<div id="M000052_source" class="dyn-source">
<pre><span class="ruby-comment cmt"># File lib/rumai/ixp/transport.rb, line 99</span>
<span class="ruby-keyword kw">def</span> <span class="ruby-identifier">release</span> <span class="ruby-identifier">member</span>
<span class="ruby-ivar">@pool</span> <span class="ruby-operator"><<</span> <span class="ruby-identifier">member</span>
<span class="ruby-keyword kw">end</span></pre>
</div>
</div>
</div>
</div>
</div>
</body>
</html>