A pipeline computing apparatus (110, 210, 510, 610, 710), comprising: a processor, configured to implement: a computing unit (120, 220, 520, 620, 720) comprising a plurality of nodes and a plurality of reception queues, and the computing unit (120, 220, 520, 620, 720) executing at least one of pipelines composed of a plurality of nodes in which the plurality of the nodes are connected via the reception queues; and a control unit (160, 260, 560, 660, 760) comprising a node monitoring unit (161, 561, 661, 761), a queue monitoring unit (162, 562, 662, 762), a priority variable calculating unit (163, 563, 663, 763), and a time allocating unit (164, 564, 664, 764), wherein the node monitoring unit (161, 561, 661, 761) acquires a node processing time, which is a time required to process one message in the node, from the node, the queue monitoring unit (162, 562, 662, 762) acquires an accumulated message amount to the reception queue from the reception queue, the priority variable calculating unit (163, 563, 663, 763) calculates a priority variable of the node based on at least the node processing time of the node and the accumulated message amount of the reception queue in a stage previous to the node, and the time allocating unit (164, 564, 664, 764) allocates an operating time to each node according to the priority variable for each node; wherein the pipeline computing apparatus is characterized in that the computing unit (120, 220, 520, 620, 720) further comprises a merger monitoring unit and a correction coefficient calculating unit (566, 666), for a pipeline in which a plurality of partial pipelines merge among the pipelines, the merger monitoring unit acquires from the queue monitoring unit (162, 562, 662, 762) accumulated message amounts of reception queues in a stage previous to nodes belonging to different partial pipelines upstream of a node at a merger point of the plurality of partial pipelines, and calculates a degree of imbalance in the accumulated message amounts of the reception queues in the stage previous to the nodes belonging to the different partial pipelines, the correction coefficient calculating unit (566, 666) calculates a correction coefficient according to the degree of imbalance for the node belonging to any of the partial pipelines among the different partial pipelines, and when the correction coefficient is calculated for the node, the time allocating unit (164, 564, 664, 764) allocates the operating time according to a value obtained by multiplying the priority variable by the correction coefficient. a computing unit (120, 220, 520, 620, 720) comprising a plurality of nodes and a plurality of reception queues, and the computing unit (120, 220, 520, 620, 720) executing at least one of pipelines composed of a plurality of nodes in which the plurality of the nodes are connected via the reception queues; and a control unit (160, 260, 560, 660, 760) comprising a node monitoring unit (161, 561, 661, 761), a queue monitoring unit (162, 562, 662, 762), a priority variable calculating unit (163, 563, 663, 763), and a time allocating unit (164, 564, 664, 764), wherein the node monitoring unit (161, 561, 661, 761) acquires a node processing time, which is a time required to process one message in the node, from the node, the queue monitoring unit (162, 562, 662, 762) acquires an accumulated message amount to the reception queue from the reception queue, the priority variable calculating unit (163, 563, 663, 763) calculates a priority variable of the node based on at least the node processing time of the node and the accumulated message amount of the reception queue in a stage previous to the node, and the time allocating unit (164, 564, 664, 764) allocates an operating time to each node according to the priority variable for each node; wherein the pipeline computing apparatus is characterized in that the computing unit (120, 220, 520, 620, 720) further comprises a merger monitoring unit and a correction coefficient calculating unit (566, 666), for a pipeline in which a plurality of partial pipelines merge among the pipelines, the merger monitoring unit acquires from the queue monitoring unit (162, 562, 662, 762) accumulated message amounts of reception queues in a stage previous to nodes belonging to different partial pipelines upstream of a node at a merger point of the plurality of partial pipelines, and calculates a degree of imbalance in the accumulated message amounts of the reception queues in the stage previous to the nodes belonging to the different partial pipelines, the correction coefficient calculating unit (566, 666) calculates a correction coefficient according to the degree of imbalance for the node belonging to any of the partial pipelines among the different partial pipelines, and when the correction coefficient is calculated for the node, the time allocating unit (164, 564, 664, 764) allocates the operating time according to a value obtained by multiplying the priority variable by the correction coefficient.