Edwin A. Suominen
Books
Blog
Photography
Software
AsynQueue API Documentation

Class Hierarchy

  • .iteration.ListConsumer
    • asynqueue.test.test_iteration.TestListConsumer.MyListConsumer - Undocumented
  • asynqueue.misc.TestMethods - Undocumented
    • asynqueue.misc.TestUniverse - Undocumented
  • asynqueue.threads.IterationGetter.IterationStopper - Undocumented
  • Exception
    • asynqueue.errors.ImplementationError - There was a problem implementing the required interface.
      • asynqueue.errors.NotReadyError - You shouldn't have called yet!
    • asynqueue.errors.ProcessError - The subprocess couldn't be reached.
    • asynqueue.errors.QueueRunError - An attempt was made to dispatch tasks when the dispatcher isn't running.
    • asynqueue.errors.ThreadError - A function call in a thread raised an exception.
    • asynqueue.errors.TimeoutError - A local worker took too long to provide a result.
    • asynqueue.errors.WorkerError - A worker ran into an exception trying to run a task.
  • logging.Handler
    • asynqueue.test.test_base.Test_TaskQueueErrors.TestHandler - Undocumented
  • logging.StreamHandler
    • asynqueue.test.testbase.TestHandler - Undocumented
  • mcmandelbrot.test.test_valuer.TestMandelbrotValuer.Yielded - Undocumented
  • object
    • asynqueue.base.LoadInfoProducer - Produces task queue loading information.
    • asynqueue.base.Priority - I provide simple, asynchronous access to a priority heap.
    • asynqueue.base.Queue - I am an asynchronous priority queue. Construct me with an item handler that can be called with each item from the queue and call shutdown when I'm done.
    • asynqueue.base.TaskQueue - I am a task queue for dispatching arbitrary callables to be run by one or more worker objects.
      • asynqueue.null.NullQueue - A TaskQueue that runs tasks in the Twisted main loop.
      • asynqueue.process.ProcessQueue - A TaskQueue that runs tasks on one or more subordinate Python processes.
      • asynqueue.threads.ThreadQueue - I am a TaskQueue for dispatching arbitrary callables to be run by a single worker thread.
    • asynqueue.info.Converter - I provide a bunch of methods for converting objects.
    • asynqueue.info.Info - Provides detailed info about function/method calls.
    • asynqueue.info.InfoHolder - An instance of me is yielded by Info.context, for you to call about info concerning a particular saved function call.
    • asynqueue.iteration.Deferator - Deferred-yielding iterator.
    • asynqueue.iteration.Delay - I let you delay things and wait for things that may take a while, in Twisted fashion.
    • asynqueue.iteration.IterationProducer - Producer of iterations from a Deferator.
    • asynqueue.iteration.ListConsumer - Bare-bones iteration consumer.
    • asynqueue.iteration.Prefetcherator - I prefetch iterations from an iterator, providing a getNext method suitable for Deferator.
    • asynqueue.process.ProcessBase - I am a base class for objects that are handy to pass as arguments to a ProcessQueue.
    • asynqueue.process.ProcessUniverse - Each process for a ProcessWorker lives in one of these.
    • asynqueue.tasks.Assignment - I represent the assignment of a single task to whichever worker object accepts me. Deep down, my real role is to provide something to fire the callback of a deferred with instead of just another deferred.
    • asynqueue.tasks.AssignmentFactory - I generate Assignment instances for workers to handle particular tasks.
    • asynqueue.tasks.Task - I represent a task that has been dispatched to a queue for running with a given scheduling niceness.
    • asynqueue.tasks.TaskFactory - I generate Task instances with the right priority setting for effective scheduling between tasks in one or more concurrently running task series.
    • asynqueue.tasks.TaskHandler - I am a Queue handler that manages one or more providers of IWorker.
    • asynqueue.test.test_interfaces.AttrBogus - Undocumented
    • asynqueue.test.test_interfaces.AttrOK - Undocumented
    • asynqueue.test.test_interfaces.NoCAttr - Undocumented
    • asynqueue.test.test_interfaces.NoIAttr - Undocumented
    • asynqueue.test.test_iteration.IteratorGetter - Undocumented
    • asynqueue.test.test_tasks.AttrBogus - Undocumented
    • asynqueue.test.test_threads.Stuff - No class docstring; 1/3 methods documented
    • asynqueue.test.test_wire.BigObject - Undocumented
    • asynqueue.test.testbase.DeferredIterable - Undocumented
    • asynqueue.test.testbase.MockTask - Undocumented
    • asynqueue.test.testbase.MsgBase - A mixin for providing a convenient message method.
      • asynqueue.test.testbase.IterationConsumer - Undocumented
      • asynqueue.test.testbase.MockWorker - Undocumented
      • asynqueue.test.testbase.ProcessProtocol - Undocumented
      • asynqueue.test.testbase.Tasks - Undocumented
        • asynqueue.test.test_threads.Test_Consumerator - Undocumented
        • asynqueue.test.test_threads.Test_Filerator - Undocumented
        • asynqueue.test.test_threads.Test_IterationGetter - Undocumented
        • asynqueue.test.test_threads.Test_OrderedItemProducer - No class docstring; 1/8 methods documented
        • asynqueue.test.test_threads.Test_ThreadQueue - Undocumented
        • asynqueue.test.test_threads.Test_ThreadWorker - Undocumented
      • asynqueue.test.testbase.TestCase - Slightly improved TestCase
        • asynqueue.test.test_base.Test_Priority - Undocumented
        • asynqueue.test.test_base.Test_TaskQueue - Undocumented
        • asynqueue.test.test_base.Test_TaskQueueErrors - Undocumented
        • asynqueue.test.test_info.Test_Functions - Undocumented
        • asynqueue.test.test_info.Test_Info - Undocumented
        • asynqueue.test.test_interfaces.TestIWorker - Undocumented
        • asynqueue.test.test_iteration.TestDeferator - Undocumented
        • asynqueue.test.test_iteration.TestDelay - Undocumented
        • asynqueue.test.test_iteration.TestIterationProducer - Undocumented
        • asynqueue.test.test_iteration.TestListConsumer - Undocumented
        • asynqueue.test.test_iteration.TestPrefetcherator - Undocumented
        • asynqueue.test.test_process.TestProcessQueue - Undocumented
        • asynqueue.test.test_process.TestProcessWorker - Undocumented
        • asynqueue.test.test_process.TestProcessWorkerStats - Undocumented
        • asynqueue.test.test_tasks.Test_AssignmentFactory - Undocumented
        • asynqueue.test.test_tasks.Test_Task - Undocumented
        • asynqueue.test.test_tasks.Test_TaskFactory - Undocumented
        • asynqueue.test.test_tasks.Test_TaskHandlerHiring - Undocumented
        • asynqueue.test.test_tasks.Test_TaskHandlerRun - Undocumented
        • asynqueue.test.test_threads.Test_Consumerator - Undocumented
        • asynqueue.test.test_threads.Test_Filerator - Undocumented
        • asynqueue.test.test_threads.Test_IterationGetter - Undocumented
        • asynqueue.test.test_threads.Test_OrderedItemProducer - No class docstring; 1/8 methods documented
        • asynqueue.test.test_threads.Test_ThreadLooper - Undocumented
        • asynqueue.test.test_threads.Test_ThreadQueue - Undocumented
        • asynqueue.test.test_threads.Test_ThreadWorker - Undocumented
        • asynqueue.test.test_util.TestCallRunner - Undocumented
        • asynqueue.test.test_util.TestDeferredTracker - Undocumented
        • asynqueue.test.test_util.TestFunctions - Undocumented
        • asynqueue.test.test_wire.Test_ChunkyString - Undocumented
        • asynqueue.test.test_wire.Test_WireRunner - Undocumented
        • asynqueue.test.test_wire.Test_WireWorker - Undocumented
        • asynqueue.test.test_workers.TestAsyncWorker - Undocumented
      • asynqueue.test.testbase.TestHandler - Undocumented
    • asynqueue.test.testbase.Picklable - Undocumented
    • asynqueue.test.testbase.RangeProducer - Produces an integer range of values like range.
    • asynqueue.test.testbase.RangeWriter - Writes an integer range of values like range to a file-like object fh and then closes it.
    • asynqueue.threads.PoolUser - Abstract base class for objects that access a global thread pool instead of starting their own threads.
      • asynqueue.threads.IterationGetter - Abstract base class for objects that munch data on one end and act like iterators to yield it on the other end.
        • asynqueue.test.test_threads.TestableIterationGetter - No class docstring; 1/1 methods documented
        • asynqueue.threads.Consumerator - I act like an IConsumer for your Twisted code and an iterator for your blocking code running via a ThreadWorker.
        • asynqueue.threads.Filerator - Stream data to me in one end and I will iterate it out the other.
      • asynqueue.threads.OrderedItemProducer - Produces blocking iterations in the order they are requested via an asynchronous function call.
    • asynqueue.threads.ThreadLooper - I run function calls in a dedicated thread.
    • asynqueue.util.CallRunner - I'm used by threads.ThreadLooper and process.ProcessUniverse.
    • asynqueue.util.DeferredTracker - I allow you to track and wait for Twisted Deferred objects without actually having received a reference to them, or interfering with their callback chains.
    • asynqueue.util.ProcessProtocol - I am a simple protocol for spawning a subordinate process.
    • asynqueue.util.TestStuff - For testing only.
    • asynqueue.va.VA - I provide version-agnostic attributes and a py3 attribute that indicates if we're running under Python 3.
    • asynqueue.wire.ChunkyString - I iterate chunks of a big string, deleting my internal reference to it when done so it can be garbage collected even if I'm not.
    • asynqueue.wire.ServerManager - I spawn one or more new Python interpreters that run a WireServer on the local machine.
    • asynqueue.wire.WireRunner - An instance of me is constructed by a WireWorkerUniverse on the server end of the AMP connection to run all tasks for its WireServer.
    • asynqueue.wire.WireServer - An AMP server for the remote end of a WireWorker.
    • asynqueue.wire.WireWorker - Runs tasks "over the wire," via Twisted AMP running on an endpoint connection.
    • asynqueue.workers.AsyncWorker - I implement an IWorker that runs tasks in the Twisted main loop.
      • mcmandelbrot.test.testbase.MockWireWorker - Undocumented
    • asynqueue.workers.ProcessWorker - I implement an IWorker that runs tasks in a dedicated worker process.
    • asynqueue.workers.ThreadWorker - I implement an IWorker that runs tasks in a dedicated worker thread.
    • mcmandelbrot.colormap.ColorMapper - I map floating-point values in the range 0.0 to 1.0 to RGB byte triplets.
    • mcmandelbrot.html.ResourceBag - Undocumented
    • mcmandelbrot.image.Imager - Call renderImage with Twisted web request objects as much as you like to write PNG images in response to them.
    • mcmandelbrot.image.RunnerToken - TODO: Implmement this with asynqueue.base.Priority to dispatch requests to runners based on how fast they've run previous ones.
    • mcmandelbrot.runner.Runner - I run a multi-process Mandelbrot Set computation operation.
    • mcmandelbrot.test.test_vroot.MockBaton - Undocumented
    • mcmandelbrot.test.testbase.DeferredIterable - Undocumented
    • mcmandelbrot.test.testbase.MsgBase - A mixin for providing a convenient message method.
      • mcmandelbrot.test.testbase.FakeFile - Undocumented
      • mcmandelbrot.test.testbase.IterationConsumer - Undocumented
      • mcmandelbrot.test.testbase.ProcessProtocol - Undocumented
      • mcmandelbrot.test.testbase.TestCase - Slightly improved TestCase
        • mcmandelbrot.test.test_main.TestRun - Undocumented
        • mcmandelbrot.test.test_runner.TestRunner - Undocumented
        • mcmandelbrot.test.test_valuer.TestMandelbrotValuer - Undocumented
        • mcmandelbrot.test.test_vroot.TestBaton - Undocumented
        • mcmandelbrot.test.test_vroot.TestHTML_VRoot - Undocumented
        • mcmandelbrot.test.test_vroot.TestVRoot - Undocumented
        • mcmandelbrot.test.test_wire.TestMandelbrotWorkerUniverse - Undocumented
        • mcmandelbrot.test.test_wire.TestRemoteRunner - Undocumented
    • mcmandelbrot.test.testbase.Picklable - Undocumented
    • mcmandelbrot.test.testbase.RangeProducer - Produces an integer range of values like xrange.
    • mcmandelbrot.test.testbase.RangeWriter - Writes an integer range of values like xrange to a file-like object fh and then closes it.
    • mcmandelbrot.valuer.MandelbrotValuer - Returns the values (number of iterations to escape, if at all, inverted) of the Mandelbrot set at point cr + i*ci in the complex plane, for a range of real values with a constant imaginary component.
    • mcmandelbrot.vroot.Baton - No summary
    • mcmandelbrot.vroot.VRoot - No summary
      • mcmandelbrot.test.test_vroot.TestableVRoot - Undocumented
    • mcmandelbrot.wire.RemoteRunner - Call setup and wait for the Deferred it returns, then you can call image as much as you like to get images streamed to you as iterations of Deferred chunks.
    • mcmandelbrot.wire.Writable - Undocumented
  • PyQt5.QtWidgets.QWidget
    • mcmandelbrot.gui.MainWindow - I act as the main window for the QApplication object.
  • twisted.internet.defer.DeferredLock
    • asynqueue.util.DeferredLock - I am a modified form of defer.DeferredLock lock that lets you shut things down when you get the lock.
  • twisted.protocols.amp.AMP
    • asynqueue.wire.WireWorker.AMP - Special disconnection-alerting AMP protocol. When my connection is made, I construct a Deferred referenced as d_lcww, which I will fire it if I get disconnected.
  • twisted.protocols.amp.Command
    • asynqueue.wire.GetNext - With a unique ID, gets the next iteration of data from an iterator or a task result so big that it had to be chunked.
    • asynqueue.wire.RunTask - Runs a task and returns the status and result.
  • twisted.protocols.amp.CommandLocator
    • asynqueue.wire.WireWorkerUniverse - Subclass me in code that runs on the remote interpreter, and then call the subclass methods via runTask.
      • asynqueue.misc.TestUniverse - Undocumented
      • mcmandelbrot.wire.MandelbrotWorkerUniverse - No summary
  • twisted.trial.unittest.TestCase
    • asynqueue.test.testbase.TestCase - Slightly improved TestCase
      • asynqueue.test.test_base.Test_Priority - Undocumented
      • asynqueue.test.test_base.Test_TaskQueue - Undocumented
      • asynqueue.test.test_base.Test_TaskQueueErrors - Undocumented
      • asynqueue.test.test_info.Test_Functions - Undocumented
      • asynqueue.test.test_info.Test_Info - Undocumented
      • asynqueue.test.test_interfaces.TestIWorker - Undocumented
      • asynqueue.test.test_iteration.TestDeferator - Undocumented
      • asynqueue.test.test_iteration.TestDelay - Undocumented
      • asynqueue.test.test_iteration.TestIterationProducer - Undocumented
      • asynqueue.test.test_iteration.TestListConsumer - Undocumented
      • asynqueue.test.test_iteration.TestPrefetcherator - Undocumented
      • asynqueue.test.test_process.TestProcessQueue - Undocumented
      • asynqueue.test.test_process.TestProcessWorker - Undocumented
      • asynqueue.test.test_process.TestProcessWorkerStats - Undocumented
      • asynqueue.test.test_tasks.Test_AssignmentFactory - Undocumented
      • asynqueue.test.test_tasks.Test_Task - Undocumented
      • asynqueue.test.test_tasks.Test_TaskFactory - Undocumented
      • asynqueue.test.test_tasks.Test_TaskHandlerHiring - Undocumented
      • asynqueue.test.test_tasks.Test_TaskHandlerRun - Undocumented
      • asynqueue.test.test_threads.Test_Consumerator - Undocumented
      • asynqueue.test.test_threads.Test_Filerator - Undocumented
      • asynqueue.test.test_threads.Test_IterationGetter - Undocumented
      • asynqueue.test.test_threads.Test_OrderedItemProducer - No class docstring; 1/8 methods documented
      • asynqueue.test.test_threads.Test_ThreadLooper - Undocumented
      • asynqueue.test.test_threads.Test_ThreadQueue - Undocumented
      • asynqueue.test.test_threads.Test_ThreadWorker - Undocumented
      • asynqueue.test.test_util.TestCallRunner - Undocumented
      • asynqueue.test.test_util.TestDeferredTracker - Undocumented
      • asynqueue.test.test_util.TestFunctions - Undocumented
      • asynqueue.test.test_wire.Test_ChunkyString - Undocumented
      • asynqueue.test.test_wire.Test_WireRunner - Undocumented
      • asynqueue.test.test_wire.Test_WireWorker - Undocumented
      • asynqueue.test.test_workers.TestAsyncWorker - Undocumented
    • mcmandelbrot.test.testbase.TestCase - Slightly improved TestCase
      • mcmandelbrot.test.test_main.TestRun - Undocumented
      • mcmandelbrot.test.test_runner.TestRunner - Undocumented
      • mcmandelbrot.test.test_valuer.TestMandelbrotValuer - Undocumented
      • mcmandelbrot.test.test_vroot.TestBaton - Undocumented
      • mcmandelbrot.test.test_vroot.TestHTML_VRoot - Undocumented
      • mcmandelbrot.test.test_vroot.TestVRoot - Undocumented
      • mcmandelbrot.test.test_wire.TestMandelbrotWorkerUniverse - Undocumented
      • mcmandelbrot.test.test_wire.TestRemoteRunner - Undocumented
  • twisted.web.resource.Resource
    • mcmandelbrot.html.ImageResource - Undocumented
    • mcmandelbrot.html.RootResource - No class docstring; 2/4 methods documented
  • twisted.web.server.Site
    • mcmandelbrot.html.MandelbrotSite - Undocumented
  • type
    • mcmandelbrot.vroot.Meta - Load class-wide lists of lines for CSS and JS
  • weave.base_info.custom_info
    • mcmandelbrot.valuer.my_info - Undocumented
  • zope.interface.Interface
    • asynqueue.interfaces.IWorker - Provided by worker objects that can have tasks assigned to them for processing.
  • zope.interface.Invalid
    • asynqueue.errors.InvariantError - An invariant of the IWorker provider did not meet requirements.

Copyright © 2015-2021 Edwin A. Suominen.

Privacy policy: I don’t sniff out, track, or share anything identifying individual visitors to this site. There are no cookies or anything in place to let me see where you go on the Internet–that’s creepy. All I get (like anyone else with a web server), is plain vanilla server logs with “referral” info about which web page sent you to this one.