proton_decay_study.generators package

Submodules

proton_decay_study.generators.base module

class proton_decay_study.generators.base.BaseDataGenerator[source]

Bases: object

Base data generator which hooks into the networks to provide an interface to the incoming data.

logger = <logging.Logger object>
next()[source]

proton_decay_study.generators.gen3d module

class proton_decay_study.generators.gen3d.Gen3D(datapaths, datasetname, labelsetname, batch_size=1)[source]

Bases: proton_decay_study.generators.base.BaseDataGenerator

Creates a generator for a list of files

input

Input shape property

Returns: A tuple representing

logger = <logging.Logger object>
next()[source]
output

Output shape property

Returns: A tuple representing the shape of the first data this picks out of the file

class proton_decay_study.generators.gen3d.Gen3DRandom(datapaths, datasetname, labelsetname, batch_size=1)[source]

Bases: proton_decay_study.generators.gen3d.Gen3D

proton_decay_study.generators.multi_file module

class proton_decay_study.generators.multi_file.MultiFileDataGenerator(datapaths, datasetname, labelsetname, batch_size=10)[source]

Bases: proton_decay_study.generators.base.BaseDataGenerator

Creates a generator for a list of files

input
logger = <logging.Logger object>
next()[source]

This should iterate over both files and datasets within a file.

output

proton_decay_study.generators.single_file module

class proton_decay_study.generators.single_file.SingleFileDataGenerator(datapath, dataset, labelset, batch_size=10)[source]

Bases: proton_decay_study.generators.base.BaseDataGenerator

Creates a generator for a single file

logger = <logging.Logger object>
next()[source]

proton_decay_study.generators.threaded_gen3d module

class proton_decay_study.generators.threaded_gen3d.SingleFileThread(datasetname, labelsetname, batch_size)[source]

Bases: threading.Thread

Wrapper thread for buffering data from a single file

activeThreads = []
static killRunThreads(frame)[source]

Sets the thread kill flag to each of the ongoing analysis threads

logger = <logging.Logger object>
queue = <Queue.Queue instance>
queueLock = <thread.lock object>
run()[source]

Loops over queue to accept new configurations

single_status()[source]
static startThreads(datasetname, labelsetname, batch_size)[source]
static status()[source]
threadLock = <thread.lock object>
visit(parent)[source]
static waitTillComplete()[source]
class proton_decay_study.generators.threaded_gen3d.ThreadedMultiFileDataGenerator(datapaths, datasetname, labelsetname, batch_size=1, nThreads=8)[source]

Bases: proton_decay_study.generators.base.BaseDataGenerator

Uses threads to pull asynchronously from files

check_and_refill()[source]
input
logger = <logging.Logger object>
next()[source]
output
status()[source]

proton_decay_study.generators.threaded_multi_file module

class proton_decay_study.generators.threaded_multi_file.SingleFileThread(datasetname, labelsetname, batch_size)[source]

Bases: threading.Thread

Represents a single file that is asynchronously

activeThreads = []
get
static killRunThreads(frame)[source]

Sets the thread kill flag to each of the ongoing analysis threads

logger = <logging.Logger object>
queue = <Queue.Queue instance>
queueLock = <thread.lock object>
run()[source]

Loops over queue to accept new configurations

static startThreads(datasetname, labelsetname, batch_size)[source]
threadLock = <thread.lock object>
static waitTillComplete()[source]
class proton_decay_study.generators.threaded_multi_file.ThreadedMultiFileDataGenerator(datapaths, datasetname, labelsetname, batch_size=1, nThreads=2)[source]

Bases: proton_decay_study.generators.base.BaseDataGenerator

Uses threads to pull asynchronously from files

input
logger = <logging.Logger object>
next()[source]
output

Module contents