るりまサーチ

最速Rubyリファレンスマニュアル検索！
28件ヒット [1-28件を表示] （0.015秒）
トップページ > ライブラリ:thread[x] > クエリ:size[x]

別のキーワード

  1. _builtin size
  2. net/imap size
  3. _builtin size?
  4. rexml/document size
  5. set size

種類

クラス

キーワード

検索結果

先頭5件

  1. Thread::Queue#size -> Integer
  2. SizedQueue
  3. Thread::SizedQueue
  4. Thread::SizedQueue.new(max) -> Thread::SizedQueue
  5. Thread::SizedQueue#<<(obj) -> ()

Thread::Queue#size -> Integer (15103.0)

キューの長さを返します。

...キューの長さを返します。

//emlist[例][ruby]{
require 'thread'
q = Queue.new

[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }

q.length # => 4
//}...

SizedQueue (6002.0)

Alias of Thread::SizedQueue

...Alias of Thread::SizedQueue...

Thread::SizedQueue (6002.0)

サイズの最大値を指定できる Thread::Queue です。

...る Thread::Queue です。

=== 例

283 より。q をサイズ 1 の SizedQueue オブジェクトに
することによって、入力される行と出力される行が同じ順序になります。
q = [] にすると入力と違った順序で行が出力されます。

require 'thread'...
...q = SizedQueue.new(1)

th = Thread.start {
while line = q.pop
print line
end
}

while l = gets
q.push(l)
end
q.push(l)

th.join...

Thread::SizedQueue.new(max) -> Thread::SizedQueue (3102.0)

Thread::SizedQueue オブジェクトを生成します。

...Thread::SizedQueue オブジェクトを生成します。

@param max キューのサイズの最大値です。...

Thread::SizedQueue#<<(obj) -> () (3002.0)

キューに与えられたオブジェクトを追加します。

...キューに与えられたオブジェクトを追加します。

キューのサイズが Thread::SizedQueue#max に達している場合は、
キューのサイズが Thread::SizedQueue#max より小さくなるまで他のスレッドに実行を譲ります。
その後、キューに与え...
...られたオブジェクトを追加します。

@param obj キューに追加したいオブジェクトを指定します。

@see Thread::Queue#push...
...ーに与えられたオブジェクトを追加します。

キューのサイズが Thread::SizedQueue#max に達している場合は、
non_block が真でなければ、キューのサイズが Thread::SizedQueue#max
より小さくなるまで他のスレッドに実行を譲ります。
そ...
...の後、キューに与えられたオブジェクトを追加します。

@param obj キューに追加したいオブジェクトを指定します。
@param non_block true を与えると、キューが一杯の時に例外 ThreadError が発生します。

@see Thread::Queue#push...

絞り込み条件を変える

Thread::SizedQueue#deq(non_block = false) -> object (3002.0)

キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。

...再開させます。

@param non_block true を与えると、キューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resourc...
...e 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}

begin
th1.join
q.pop(true)
rescue => e
p e
p e.message
end

# => resource1
# resource2
# resource3
# => #<ThreadErr...
...or: queue empty>
# => "queue empty"
//}

@see Thread::Queue#pop...

Thread::SizedQueue#enq(obj) -> () (3002.0)

キューに与えられたオブジェクトを追加します。

...キューに与えられたオブジェクトを追加します。

キューのサイズが Thread::SizedQueue#max に達している場合は、
キューのサイズが Thread::SizedQueue#max より小さくなるまで他のスレッドに実行を譲ります。
その後、キューに与え...
...られたオブジェクトを追加します。

@param obj キューに追加したいオブジェクトを指定します。

@see Thread::Queue#push...

Thread::SizedQueue#enq(obj, non_block = false) -> () (3002.0)

キューに与えられたオブジェクトを追加します。

...ーに与えられたオブジェクトを追加します。

キューのサイズが Thread::SizedQueue#max に達している場合は、
non_block が真でなければ、キューのサイズが Thread::SizedQueue#max
より小さくなるまで他のスレッドに実行を譲ります。
そ...
...の後、キューに与えられたオブジェクトを追加します。

@param obj キューに追加したいオブジェクトを指定します。
@param non_block true を与えると、キューが一杯の時に例外 ThreadError が発生します。

@see Thread::Queue#push...

Thread::SizedQueue#max -> Integer (3002.0)

キューの最大サイズを返します。

...キューの最大サイズを返します。

//emlist[例][ruby]{
q = SizedQueue.new(4)
q.max # => 4
//}...

Thread::SizedQueue#max=(n) (3002.0)

キューの最大サイズを設定します。

...キューの最大サイズを設定します。

@param n キューの最大サイズを指定します。

//emlist[例][ruby]{
require 'thread'
q = SizedQueue.new(4)
q.max # => 4
q.max = 5
q.max # => 5
//}...

絞り込み条件を変える

Thread::SizedQueue#pop(non_block = false) -> object (3002.0)

キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。

...再開させます。

@param non_block true を与えると、キューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resourc...
...e 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}

begin
th1.join
q.pop(true)
rescue => e
p e
p e.message
end

# => resource1
# resource2
# resource3
# => #<ThreadErr...
...or: queue empty>
# => "queue empty"
//}

@see Thread::Queue#pop...

Thread::SizedQueue#push(obj) -> () (3002.0)

キューに与えられたオブジェクトを追加します。

...キューに与えられたオブジェクトを追加します。

キューのサイズが Thread::SizedQueue#max に達している場合は、
キューのサイズが Thread::SizedQueue#max より小さくなるまで他のスレッドに実行を譲ります。
その後、キューに与え...
...られたオブジェクトを追加します。

@param obj キューに追加したいオブジェクトを指定します。

@see Thread::Queue#push...

Thread::SizedQueue#push(obj, non_block = false) -> () (3002.0)

キューに与えられたオブジェクトを追加します。

...ーに与えられたオブジェクトを追加します。

キューのサイズが Thread::SizedQueue#max に達している場合は、
non_block が真でなければ、キューのサイズが Thread::SizedQueue#max
より小さくなるまで他のスレッドに実行を譲ります。
そ...
...の後、キューに与えられたオブジェクトを追加します。

@param obj キューに追加したいオブジェクトを指定します。
@param non_block true を与えると、キューが一杯の時に例外 ThreadError が発生します。

@see Thread::Queue#push...

Thread::SizedQueue#shift(non_block = false) -> object (3002.0)

キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。

...再開させます。

@param non_block true を与えると、キューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resourc...
...e 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}

begin
th1.join
q.pop(true)
rescue => e
p e
p e.message
end

# => resource1
# resource2
# resource3
# => #<ThreadErr...
...or: queue empty>
# => "queue empty"
//}

@see Thread::Queue#pop...

Thread::ConditionVariable (8.0)

スレッドの同期機構の一つである状態変数を実現するクラスです。

...クラスです。

以下も ConditionVariable を理解するのに参考になります。

https://ruby-doc.com/docs/ProgrammingRuby/html/tut_threads.html#UF

=== Condition Variable とは

あるスレッド A が排他領域で動いていたとします。スレッド A は現在空いてい...
...tex = Mutex.new
cv = ConditionVariable.new

a = Thread.start {
mutex.synchronize {
...
while (条件が満たされない)
cv.wait(mutex)
end
...
}
}

b = Thread.start {
mutex.synchronize {
# 上の...
...て wait しています。

require 'thread'

class TinyQueue
def initialize(max=2)
@max = max
@full = ConditionVariable.new
@empty = ConditionVariable.new
@mutex = Mutex.new
@q = []
end

def count
@q.size
end

def enq(v)
@mutex.sync...

絞り込み条件を変える

Thread::Queue#length -> Integer (3.0)

キューの長さを返します。

...キューの長さを返します。

//emlist[例][ruby]{
require 'thread'
q = Queue.new

[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }

q.length # => 4
//}...

検索対象のドキュメントは るりまプロジェクト の成果物です。

検索エンジンは Groonga 13.0.0 を使っています。

Groongaは Rroonga 12.1.0 経由で利用しています。

Powered by Ruby 3.1.2.

るりまサーチのリポジトリ は GitHub 上にあります。