diff --git a/platform/windows/pcap.cpp b/platform/windows/pcap.cpp
index c8a65b1..f5de8b4 100644
--- a/platform/windows/pcap.cpp
+++ b/platform/windows/pcap.cpp
@@ -285,26 +285,34 @@ void PCAP::writeTask() {
 	pcap_send_queue* queue1 = pcap.sendqueue_alloc(128000);
 	pcap_send_queue* queue2 = pcap.sendqueue_alloc(128000);
 	pcap_send_queue* queue = queue1;
-	std::vector<uint8_t> extraData;
 
 	while(!closing) {
-		if(!writeQueue.wait_dequeue_timed(writeOp, std::chrono::milliseconds(100)))
-			continue;
+		// Potentially, we added frames to a second queue faster than the other thread was able to hand the first
+		// off to the kernel. In that case, wait for a minimal amount of time before checking whether we can
+		// transmit it again.
+		if(writeQueue.wait_dequeue_timed(writeOp, std::chrono::milliseconds(queue->len ? 1 : 100))) {
+			unsigned int i = 0;
+			do {
+				ethPacketizer.inputDown(std::move(writeOp.bytes));
+				if(i++ >= (queue->maxlen - queue->len) / 1518 / 3)
+					break; // Not safe to try to fit any more packets in this queue, let it transmit and come around again
+			} while(writeQueue.try_dequeue(writeOp));
 
-		unsigned int i = 0;
-		do {
-			ethPacketizer.inputDown(std::move(writeOp.bytes));
-		} while(writeQueue.try_dequeue(writeOp) && i++ < (queue->maxlen - queue->len) / 1518 / 3);
-
-		for(const auto& data : ethPacketizer.outputDown()) {
-			pcap_pkthdr header = {};
-			header.caplen = header.len = bpf_u_int32(data.size());
-			if(pcap.sendqueue_queue(queue, &header, data.data()) == -1)
-				report(APIEvent::Type::FailedToWrite, APIEvent::Severity::EventWarning);
+			for(const auto& data : ethPacketizer.outputDown()) {
+				pcap_pkthdr header = {};
+				header.caplen = header.len = bpf_u_int32(data.size());
+				if(pcap.sendqueue_queue(queue, &header, data.data()) != 0)
+					report(APIEvent::Type::FailedToWrite, APIEvent::Severity::EventWarning);
+			}
 		}
 		
 		std::unique_lock<std::mutex> lk(transmitQueueMutex);
-		if(!transmitQueue || queue->len + (1518*2) >= queue->maxlen) { // Checking if we want to swap sendqueues with the transmitTask
+		// Check if we want to transmit our current queue
+		// If we're not currently transmitting a queue, let this one transmit immediately for good latency
+		// If our queue is full and we're transmitting the other, we can't accept any more packets out of the writeQueue
+		// In that case we're putting as many packets into the driver as possible, so wait for it to be free
+		// This puts the backpressure on the writeQueue
+		if(queue->len && (!transmitQueue || queue->len + (1518*2) >= queue->maxlen)) {
 			if(transmitQueue) // Need to wait for the queue to become available
 				transmitQueueCV.wait(lk, [this] { return !transmitQueue; });