org.knime.base.node.parallel
Class ThreadedNodeModel

java.lang.Object
  extended by org.knime.core.node.NodeModel
      extended by org.knime.base.node.parallel.AbstractParallelNodeModel
          extended by org.knime.base.node.parallel.ThreadedNodeModel

Deprecated. Use either the ThreadedColAppenderNodeModel if you want to add columns to the input tables and the number of rows stays the same, or the ThreadedTableBuilderNodeModel if you want to build a completely new table.

@Deprecated
public abstract class ThreadedNodeModel
extends AbstractParallelNodeModel

This model is an extension of the AbstractParallelNodeModel that uses a sub pool of the global KNIME thread pool. The default maximum number of threads for each of these nodes is DEFAULT_MAX_THREAD_COUNT which is currently set to the number of CPUs + 1 (this is only a rule of thumb, nothing more). The maximum number can be adjusted by calling setMaxThreads(int) but the real maximum is still determined by the global thread pool.

Author:
Thorsten Meinl, University of Konstanz

Field Summary
static int DEFAULT_MAX_THREAD_COUNT
          Deprecated. The default maximum number of threads for each threaded node.
 
Fields inherited from class org.knime.base.node.parallel.AbstractParallelNodeModel
m_workers
 
Constructor Summary
ThreadedNodeModel(int nrDataIns, int nrDataOuts, int chunkSize)
          Deprecated. Creates a new AbstractParallelNodeModel.
 
Method Summary
 void setMaxThreads(int count)
          Deprecated. Sets the maximum number of threads that may be used by this node.
 
Methods inherited from class org.knime.base.node.parallel.AbstractParallelNodeModel
execute, executeByChunk, getChunkSize, prepareExecute, setChunkSize
 
Methods inherited from class org.knime.core.node.NodeModel
addWarningListener, configure, configure, continueLoop, execute, executeModel, getInHiLiteHandler, getLoopEndNode, getLoopStartNode, getNrInPorts, getNrOutPorts, getOutHiLiteHandler, getWarningMessage, loadInternals, loadValidatedSettingsFrom, notifyViews, notifyWarningListeners, peekFlowVariableDouble, peekFlowVariableInt, peekFlowVariableString, peekScopeVariableDouble, peekScopeVariableInt, peekScopeVariableString, pushFlowVariableDouble, pushFlowVariableInt, pushFlowVariableString, pushScopeVariableDouble, pushScopeVariableInt, pushScopeVariableString, removeWarningListener, reset, saveInternals, saveSettingsTo, setInHiLiteHandler, setWarningMessage, stateChanged, validateSettings
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_MAX_THREAD_COUNT

public static final int DEFAULT_MAX_THREAD_COUNT
Deprecated. 
The default maximum number of threads for each threaded node.

Constructor Detail

ThreadedNodeModel

public ThreadedNodeModel(int nrDataIns,
                         int nrDataOuts,
                         int chunkSize)
Deprecated. 
Creates a new AbstractParallelNodeModel.

Parameters:
nrDataIns - The number of DataTable elements expected as inputs.
nrDataOuts - The number of DataTable objects expected at the output.
chunkSize - the default number of rows in the chunked DataTables
Method Detail

setMaxThreads

public void setMaxThreads(int count)
Deprecated. 
Sets the maximum number of threads that may be used by this node.

Parameters:
count - the maximum thread count


Copyright, 2003 - 2010. All rights reserved.
University of Konstanz, Germany.
Chair for Bioinformatics and Information Mining, Prof. Dr. Michael R. Berthold.
You may not modify, publish, transmit, transfer or sell, reproduce, create derivative works from, distribute, perform, display, or in any way exploit any of the content, in whole or in part, except as otherwise expressly permitted in writing by the copyright owner or as specified in the license file distributed with this product.