sig
  module type Config = sig val debug : bool val nagain : int end
  module type Enumerable =
    sig
      type t
      type elt
      type enum
      val start :
        JoinPool.Shared.Enumerable.t -> JoinPool.Shared.Enumerable.enum
      val step :
        JoinPool.Shared.Enumerable.enum ->
        (JoinPool.Shared.Enumerable.elt * JoinPool.Shared.Enumerable.enum)
        option
    end
  type ('a, 'b) worker = 'a -> 'b
  type subtask_id = int
  type ('a, 'b) interruptible_worker =
      JoinPool.Shared.subtask_id * 'a -> 'b option
  type kill = JoinPool.Shared.subtask_id Join.chan
  module type S =
    sig
      type elt
      type collection
      type ('a, 'b) t = {
        register :
          (JoinPool.Shared.S.elt, 'a) JoinPool.Shared.worker Join.chan;
        register_interruptible :
          ((JoinPool.Shared.S.elt, 'a) JoinPool.Shared.interruptible_worker *
           JoinPool.Shared.kill)
          Join.chan;
        fold : JoinPool.Shared.S.collection -> ('a -> 'b -> 'b) -> 'b -> 'b;
      }
      val create : unit -> ('a, 'b) JoinPool.Shared.S.t
    end
  module Make :
    functor (C : Config) ->
      functor (E : Enumerable) ->
        sig
          type elt = E.elt
          type collection = E.t
          type ('a, 'b) t = {
            register : (elt, 'a) worker Join.chan;
            register_interruptible :
              ((elt, 'a) interruptible_worker * kill) Join.chan;
            fold : collection -> ('a -> 'b -> 'b) -> 'b -> 'b;
          }
          val create : unit -> ('a, 'b) t
        end
end