| File | Code |
|---|---|
JNTHN/cro…/Services.pm6 :76: |
sub tap-on(Supply:D $supply, Scheduler $scheduler) { |
JSTOWE/Audio-Libshout…/Libshout.pm :665: |
$!helper-promise = Promise.start(&send, scheduler => ThreadPoolScheduler.new); |
JSTOWE/Manifesto…/030-failures.t :8: |
my $*SCHEDULER = ThreadPoolScheduler.new(max_threads => 1); |
MZIESCHA/Bailador-Plugin-NamedQueries…/README.md :40: |
namespace: R3Scheduler::Db::Queries |
MZIESCHA/Bailador-Plugin-NamedQueries…/NamedQueries.pm :102: |
namespace: R3Scheduler::Db::Queries |
FCO/Test-Fuzz…/classes :19: |
CurrentThreadScheduler |
FCO/Test-Fuzz…/classes :97: |
ThreadPoolScheduler |
FCO/test-time…/.travis.yml :6: |
- zef install Test::Scheduler --/test |
FCO/test-time…/META6.json :9: |
"Test::Scheduler" |
FCO/test-time…/README.md :6: |
Use **Test::Scheduler** to use on your tests, not only Promises, but **sleep**, **now** and time. |
FCO/test-time…/README.md :25: |
Or you can use `$*SCHEDULER.advance-by: 10` as you would when using **Test::Scheduler** |
FCO/test-time…/Time.pm6 :5: |
Use B<Test::Scheduler> to use on your tests, not only Promises, but B<sleep>, B<now> and time. |
FCO/test-time…/Time.pm6 :24: |
Or you can use C<$*SCHEDULER.advance-by: 10> as you would when using B<Test::Scheduler> |
FCO/test-time…/Time.pm6 :27: |
use Test::Scheduler; |
FCO/test-time…/Time.pm6 :34: |
sub mock-time(Instant $now is copy = now, Bool :$auto-advance = False, Rat() :$interval = .1 --> Scheduler) is export { |
FCO/test-time…/Time.pm6 :35: |
my $*SCHEDULER = Test::Scheduler.new: :virtual-time($now); |
azawawi/perl6-gtk-simpler…/GTK-Simpler.md :95: |
Returns a GTK::Simple::Scheduler object. |
azawawi/perl6-gtk-simpler…/Simpler.pm6 :135: |
Returns a GTK::Simple::Scheduler object. |
azawawi/perl6-gtk-simpler…/Simpler.pm6 :138: |
require GTK::Simple::Scheduler; |
azawawi/perl6-gtk-simpler…/Simpler.pm6 :139: |
return ::('GTK::Simple::Scheduler').new(|args); |
finanalyst/pod-cached…/Cached.pm6 :141: |
PROCESS::<$SCHEDULER> = ThreadPoolScheduler.new(initial_threads => 0, max_threads => MAX-COMPILATIONS); |
jnthn/p6-concurrent-progress…/META6.json :9: |
"test-depends" : ["Test::Scheduler"], |
jnthn/p6-concurrent-progress…/min-interval.t :3: |
use Test::Scheduler; |
jnthn/p6-concurrent-progress…/min-interval.t :6: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-concurrent-progress…/min-interval.t :52: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/META6.json :3: |
"name" : "Test::Scheduler", |
jnthn/p6-test-scheduler…/META6.json :5: |
"description" : "An implementation of the Perl 6 Scheduler role with virtualized time.", |
jnthn/p6-test-scheduler…/META6.json :7: |
"Test::Scheduler" : "lib/Test/Scheduler.pm6" |
jnthn/p6-test-scheduler…/README.md :1: |
# Test::Scheduler |
jnthn/p6-test-scheduler…/README.md :3: |
An implementation of the Perl 6 `Scheduler` role that uses virtualized time. |
jnthn/p6-test-scheduler…/README.md :12: |
use Test::Scheduler; |
jnthn/p6-test-scheduler…/README.md :31: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/Scheduler.pm6 :5: |
class X::Test::Scheduler::BackInTime is Exception { |
jnthn/p6-test-scheduler…/Scheduler.pm6 :11: |
class Test::Scheduler does Scheduler { |
jnthn/p6-test-scheduler…/Scheduler.pm6 :166: |
die X::Test::Scheduler::BackInTime.new if $seconds < 0; |
jnthn/p6-test-scheduler…/Scheduler.pm6 :173: |
die X::Test::Scheduler::BackInTime.new if $new-virtual-time < $!virtual-time; |
jnthn/p6-test-scheduler…/not-time-based.t :2: |
use Test::Scheduler; |
jnthn/p6-test-scheduler…/not-time-based.t :5: |
my $*SCHEDULER = Test::Scheduler.new(); |
jnthn/p6-test-scheduler…/not-time-based.t :13: |
my $*SCHEDULER = Test::Scheduler.new(); |
jnthn/p6-test-scheduler…/synopsis.t :2: |
use Test::Scheduler; |
jnthn/p6-test-scheduler…/synopsis.t :21: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :2: |
use Test::Scheduler; |
jnthn/p6-test-scheduler…/virtualized-time.t :5: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :17: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :32: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :52: |
throws-like { $*SCHEDULER.advance-by(-1) }, X::Test::Scheduler::BackInTime; |
jnthn/p6-test-scheduler…/virtualized-time.t :63: |
my $*SCHEDULER = Test::Scheduler.new(virtual-time => $sim-time); |
jnthn/p6-test-scheduler…/virtualized-time.t :92: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :105: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :114: |
my $*SCHEDULER = Test::Scheduler.new(virtual-time => $sim-time); |
jnthn/p6-test-scheduler…/virtualized-time.t :135: |
X::Test::Scheduler::BackInTime; |
jnthn/p6-test-scheduler…/virtualized-time.t :140: |
my $*SCHEDULER = Test::Scheduler.new(virtual-time => $sim-time); |
jnthn/p6-test-scheduler…/virtualized-time.t :171: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :192: |
my $*SCHEDULER = Test::Scheduler.new(); |
jnthn/p6-test-scheduler…/virtualized-time.t :203: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :224: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :248: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :272: |
my $*SCHEDULER = Test::Scheduler.new; |
jnthn/p6-test-scheduler…/virtualized-time.t :282: |
my $*SCHEDULER = Test::Scheduler.new; |
perl6/Blin…/blin.p6 :317: |
# ThreadPoolScheduler. Note that as of today machines with |
perl6/doc…/concurrency.pod6 :27: |
(e.g., L<Thread|/type/Thread> and L<Scheduler|/type/Scheduler>) and use the higher-level interfaces. |
perl6/doc…/concurrency.pod6 :696: |
=head2 Schedulers |
perl6/doc…/concurrency.pod6 :699: |
implement the interface defined by the role L<Scheduler|/type/Scheduler>. The intent |
perl6/doc…/concurrency.pod6 :711: |
by the L<Scheduler|/type/Scheduler> interface) is the C<cue> method: |
perl6/doc…/concurrency.pod6 :716: |
manner determined by the adverbs (as documented in L<Scheduler|/type/Scheduler>) using |
perl6/doc…/concurrency.pod6 :738: |
Despite the apparent advantage the L<Scheduler|/type/Scheduler> interface provides over |
perl6/doc…/concurrency.pod6 :750: |
=head3 ThreadPoolScheduler |
perl6/doc…/concurrency.pod6 :752: |
The L<ThreadPoolScheduler|/type/ThreadPoolScheduler> is the default scheduler, it maintains a pool |
perl6/doc…/concurrency.pod6 :762: |
=head3 CurrentThreadScheduler |
perl6/doc…/concurrency.pod6 :764: |
The L<CurrentThreadScheduler|/type/CurrentThreadScheduler> is a very simple scheduler that will always |
perl6/doc…/variables.pod6 :1501: |
This is a L<ThreadPoolScheduler|/type/ThreadPoolScheduler> object representing the current default |
perl6/doc…/variables.pod6 :1511: |
my $*SCHEDULER = ThreadPoolScheduler.new( max_threads => 128 ); |
perl6/doc…/Cancellation.pod6 :5: |
=SUBTITLE Removal of a task from a Scheduler before normal completion |
perl6/doc…/Cancellation.pod6 :9: |
A low level part of the Perl 6 L<concurrency|/language/concurrency#Schedulers> |
perl6/doc…/Cancellation.pod6 :10: |
system. Some L<Scheduler|/type/Scheduler> objects return a C<Cancellation> with the |
perl6/doc…/Cancellation.pod6 :11: |
L<.cue|/type/Scheduler#method_cue> method which can be used to cancel the |
perl6/doc…/CurrentThreadScheduler.pod6 :3: |
=TITLE class CurrentThreadScheduler |
perl6/doc…/CurrentThreadScheduler.pod6 :5: |
=SUBTITLE Scheduler that synchronously executes code on the current thread |
perl6/doc…/CurrentThreadScheduler.pod6 :8: |
class CurrentThreadScheduler does Scheduler {} |
perl6/doc…/CurrentThreadScheduler.pod6 :10: |
C<CurrentThreadScheduler> executes tasks on the current threads. This means |
perl6/doc…/CurrentThreadScheduler.pod6 :11: |
that L<method cue|/type/Scheduler#method_cue> blocks until the code has |
perl6/doc…/Scheduler.pod6 :3: |
=TITLE role Scheduler |
perl6/doc…/Scheduler.pod6 :7: |
role Scheduler { |
perl6/doc…/Scheduler.pod6 :17: |
C<Scheduler> |
perl6/doc…/Supply.pod6 :151: |
method schedule-on(Supply:D: Scheduler $scheduler) |
perl6/doc…/ThreadPool.p6 :6: |
=SUBTITLE Instrument for collecting ThreadPoolScheduler data |
perl6/doc…/ThreadPoolScheduler.pod6 :3: |
=TITLE class ThreadPoolScheduler |
perl6/doc…/ThreadPoolScheduler.pod6 :5: |
=SUBTITLE Scheduler that distributes work among a pool of threads |
perl6/doc…/ThreadPoolScheduler.pod6 :8: |
class ThreadPoolScheduler does Scheduler {} |
perl6/doc…/ThreadPoolScheduler.pod6 :11: |
The C<ThreadPoolScheduler> has a range of number of threads that it maintains, |
perl6/doc…/ThreadPoolScheduler.pod6 :22: |
Creates a new C<ThreadPoolScheduler> object with the given range of threads to |
perl6/doc…/type-graph.txt :178: |
role Scheduler |
perl6/doc…/type-graph.txt :179: |
class CurrentThreadScheduler does Scheduler |
perl6/doc…/type-graph.txt :180: |
class ThreadPoolScheduler does Scheduler |
perl6/gtk-simple…/META6.json :43: |
"GTK::Simple::Scheduler" : "lib/GTK/Simple/Scheduler.pm6", |
perl6/gtk-simple…/Simple.pm6 :8: |
need GTK::Simple::Scheduler; |
perl6/gtk-simple…/Scheduler.pm6 :8: |
unit class GTK::Simple::Scheduler does Scheduler; |
perl6/gtk-simple…/Scheduler.pm6 :13: |
my &idle_cb = sub ($a) { GTK::Simple::Scheduler.process-queue; return 0 }; |
perl6/gtk-simple…/Scheduler.pm6 :16: |
die "GTK::Simple::Scheduler does not support at" if $at; |
perl6/gtk-simple…/Scheduler.pm6 :17: |
die "GTK::Simple::Scheduler does not support in" if $in; |
perl6/gtk-simple…/Scheduler.pm6 :18: |
die "GTK::Simple::Scheduler does not support every" if $every; |
perl6/gtk-simple…/Scheduler.pm6 :19: |
die "GTK::Simple::Scheduler does not support times" if $times; |
perl6/gtk-simple…/01-sanity.t :6: |
use GTK::Simple::Scheduler; |
perl6/gtk-simple…/01-sanity.t :13: |
lives-ok {GTK::Simple::Scheduler.new.cue: {$g.exit}} |
perl6/perl6-pod-to-bigpage…/pod2onepage :33: |
PROCESS::<$SCHEDULER> = ThreadPoolScheduler.new(initial_threads => 0, max_threads => $threads); |
scovit/Scheduler-DRMAA…/.gitignore :8: |
/Scheduler-DRMAA-* |
scovit/Scheduler-DRMAA…/.gitrepo :7: |
remote = git@github.com:scovit/Scheduler-DRMAA.git |
scovit/Scheduler-DRMAA…/META6.json :12: |
"name" : "Scheduler::DRMAA", |
scovit/Scheduler-DRMAA…/META6.json :24: |
"Scheduler::DRMAA" : "lib/Scheduler/DRMAA.pm6", |
scovit/Scheduler-DRMAA…/META6.json :28: |
"source-url" : "git://github.com/scovit/Scheduler-DRMAA.git", |
scovit/Scheduler-DRMAA…/README.md :1: |
|
scovit/Scheduler-DRMAA…/README.md :6: |
Scheduler::DRMAA - Bindings for the DRMAA cluster library |
scovit/Scheduler-DRMAA…/README.md :19: |
Scheduler::DRMAA are the Perl 6 bindings for the DRMAA library. You can use them in order to submit pipelines of work to a supercomputer. We provide two different interfaces: |
scovit/Scheduler-DRMAA…/TODO :8: |
- A less deterministic Perl 6 Scheduler role in core |
scovit/Scheduler-DRMAA…/DRMAA.pm6 :4: |
# see Scheduler::DRMAA for the documentation |
scovit/Scheduler-DRMAA…/DRMAA.pm6 :2: |
unit class Scheduler::DRMAA:ver<0.0.1>; |
scovit/Scheduler-DRMAA…/DRMAA.pm6 :9: |
Scheduler::DRMAA - Bindings for the DRMAA cluster library |
scovit/Scheduler-DRMAA…/DRMAA.pm6 :21: |
Scheduler::DRMAA are the Perl 6 bindings for the DRMAA library. You can use |
Created
January 26, 2020 12:55
-
-
Save Whateverable/4907290d14adf0a8af133787f4555ace to your computer and use it in GitHub Desktop.
greppable6
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Scheduler |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment