X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=libs%2Fardour%2Fardour%2Fworker.h;h=6e1a7c91f1849f6cdb011fac5621987acd500194;hb=940707e327014f30791d75be00ccbd33b0a0555d;hp=4f3ff54bc10782898d32a711e7826f246732cc29;hpb=9ab45f37c6fa866762fae8bb01f72eacdc75abd3;p=ardour.git

diff --git a/libs/ardour/ardour/worker.h b/libs/ardour/ardour/worker.h
index 4f3ff54bc1..6e1a7c91f1 100644
--- a/libs/ardour/ardour/worker.h
+++ b/libs/ardour/ardour/worker.h
@@ -1,5 +1,5 @@
 /*
-  Copyright (C) 2012 Paul Davis
+  Copyright (C) 2012-2016 Paul Davis
   Author: David Robillard
 
   This program is free software; you can redistribute it and/or modify
@@ -25,21 +25,25 @@
 #include <glibmm/threads.h>
 
 #include "pbd/ringbuffer.h"
-#include "pbd/semaphore.h"
+#include "pbd/semutils.h"
+
+#include "ardour/libardour_visibility.h"
 
 namespace ARDOUR {
 
+class Worker;
+
 /**
    An object that needs to schedule non-RT work in the audio thread.
 */
-class Workee {
+class LIBARDOUR_API Workee {
 public:
 	virtual ~Workee() {}
 
 	/**
 	   Do some work in the worker thread.
 	*/
-	virtual int work(uint32_t size, const void* data) = 0;
+	virtual int work(Worker& worker, uint32_t size, const void* data) = 0;
 
 	/**
 	   Handle a response from the worker thread in the audio thread.
@@ -48,12 +52,16 @@ public:
 };
 
 /**
-   A worker thread for non-realtime tasks scheduled in the audio thread.
+   A worker for non-realtime tasks scheduled from another thread.
+
+   A worker may be a separate thread that runs to execute scheduled work
+   asynchronously, or unthreaded, in which case work is executed immediately
+   upon scheduling by the calling thread.
 */
-class Worker
+class LIBARDOUR_API Worker
 {
 public:
-	Worker(Workee* workee, uint32_t ring_size);
+	Worker(Workee* workee, uint32_t ring_size, bool threaded=true);
 	~Worker();
 
 	/**
@@ -73,6 +81,16 @@ public:
 	*/
 	void emit_responses();
 
+	/**
+	   Enable or disable synchronous execution.
+
+	   If enabled, all work is performed immediately in schedule() regardless
+	   of whether or not the worker is threaded.  This is used for exporting,
+	   where we want to temporarily execute all work synchronously but the
+	   worker is typically used threaded for live rolling.
+	*/
+	void set_synchronous(bool synchronous) { _synchronous = synchronous; }
+
 private:
 	void run();
 	/**
@@ -81,9 +99,9 @@ private:
 	   Handle the unlikley edge-case, if we're called in between the
 	   responder writing 'size' and 'data'.
 
-		 @param rb the ringbuffer to check
-		 @return true if the message is complete, false otherwise
-	 */
+	   @param rb the ringbuffer to check
+	   @return true if the message is complete, false otherwise
+	*/
 	bool verify_message_completeness(RingBuffer<uint8_t>* rb);
 
 	Workee*                _workee;
@@ -91,9 +109,9 @@ private:
 	RingBuffer<uint8_t>*   _responses;
 	uint8_t*               _response;
 	PBD::Semaphore         _sem;
-	bool                   _exit;
 	Glib::Threads::Thread* _thread;
-
+	bool                   _exit;
+	bool                   _synchronous;
 };
 
 } // namespace ARDOUR